Java Executor执行器如何控制并发数

在Java中，ExecutorService接口提供了一种灵活的方式来控制并发任务的数量。你可以通过以下几种方式来控制并发数：

1. 使用固定大小的线程池： 通过Executors.newFixedThreadPool(int nThreads)方法创建一个固定大小的线程池。这个线程池会保持最多nThreads个线程同时运行。

   ExecutorService executor = Executors.newFixedThreadPool(5);
   for (int i = 0; i < 10; i++) {
       executor.submit(new Task());
   }
   executor.shutdown();
   

2. 使用单线程执行器： 如果你希望任务按顺序执行，可以使用Executors.newSingleThreadExecutor()方法创建一个单线程的执行器。

   ExecutorService executor = Executors.newSingleThreadExecutor();
   for (int i = 0; i < 10; i++) {
       executor.submit(new Task());
   }
   executor.shutdown();
   

3. 使用自定义线程池： 你可以使用ThreadPoolExecutor类来创建一个自定义的线程池，这样可以更精细地控制线程池的行为。

   ThreadPoolExecutor executor = new ThreadPoolExecutor(
       5, // 核心线程数
       10, // 最大线程数
       60L, TimeUnit.SECONDS, // 线程空闲时间
       new LinkedBlockingQueue<>(100) // 任务队列
   );
   for (int i = 0; i < 100; i++) {
       executor.submit(new Task());
   }
   executor.shutdown();
   

4. 使用Semaphore控制并发数： Semaphore类可以用来限制同时访问某一资源的线程数量。你可以使用Semaphore来控制并发任务的数量。

   Semaphore semaphore = new Semaphore(5); // 允许最多5个线程同时访问
   for (int i = 0; i < 10; i++) {
       new Thread(() -> {
           try {
               semaphore.acquire();
               new Task().run();
           } catch (InterruptedException e) {
               e.printStackTrace();
           } finally {
               semaphore.release();
           }
       }).start();
   }
   

5. 使用CompletableFuture控制并发数： CompletableFuture提供了更高级的异步编程模型，可以用来控制并发任务的数量。

   ExecutorService executor = Executors.newFixedThreadPool(5);
   List<CompletableFuture<Void>> futures = new ArrayList<>();
   for (int i = 0; i < 10; i++) {
       CompletableFuture<Void> future = CompletableFuture.runAsync(new Task(), executor);
       futures.add(future);
   }
   CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
   executor.shutdown();
   

通过这些方法，你可以有效地控制Java中的并发任务数量，确保系统资源得到合理利用。