在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个。当所有任务完成后,我们关闭线程池。