在Java中，要控制新建线程的并发数量，可以使用线程池（ExecutorService）来实现。线程池允许你限制同时运行的线程数量，从而有效地管理系统资源。以下是一个简单的示例，展示了如何使用ExecutorService来限制线程并发数量：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个固定大小的线程池，最多同时运行3个线程
ExecutorService executorService = Executors.newFixedThreadPool(3);
// 提交任务到线程池
for (int i = 0; i < 10; i++) {
executorService.submit(() -> {
System.out.println("Task executed by thread: " + Thread.currentThread().getName());
try {
// 模拟任务执行耗时
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
}
// 关闭线程池，不再接受新的任务
executorService.shutdown();
try {
// 等待所有任务完成
if (!executorService.awaitTermination(30, TimeUnit.SECONDS)) {
executorService.shutdownNow();
}
} catch (InterruptedException e) {
executorService.shutdownNow();
}
}
}
在这个示例中，我们创建了一个固定大小为3的线程池，然后提交了10个任务到线程池。线程池会自动分配任务给空闲的线程，并确保同时运行的线程数量不超过3个。当所有任务完成后，我们关闭线程池。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，请发送邮件至 55@qq.com 举报，一经查实，本站将立刻删除。转转请注明出处：https://www.szhjjp.com/n/1201423.html
