Java ExecutorService如何实现并发控制

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。通过使用ExecutorService，你可以轻松地实现并发控制，因为它允许你管理多个线程的执行。以下是使用ExecutorService实现并发控制的几种方法：

1. 创建固定大小的线程池： 使用Executors.newFixedThreadPool(int nThreads)方法可以创建一个固定大小的线程池。这个线程池会保持最多nThreads个线程同时运行。如果所有线程都在忙于执行任务，新的任务将会等待直到有空闲线程。

   ExecutorService executor = Executors.newFixedThreadPool(5);
   for (int i = 0; i < 10; i++) {
       final int taskNumber = i;
       executor.submit(() -> {
           System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
           // 执行任务逻辑
       });
   }
   executor.shutdown();
   

2. 使用submit()方法提交任务： submit()方法可以提交一个Callable或Runnable任务，并返回一个Future对象。你可以使用这个Future对象来检查任务是否完成，或者等待任务完成并获取结果。

   Future<?> future = executor.submit(() -> {
       // 执行任务逻辑
   });
   try {
       future.get(); // 等待任务完成
   } catch (InterruptedException | ExecutionException e) {
       e.printStackTrace();
   }
   

3. 使用shutdown()和awaitTermination()方法优雅地关闭线程池： 当你不再需要线程池时，应该调用shutdown()方法来拒绝新的任务提交，并允许当前正在执行的任务完成。然后，你可以使用awaitTermination()方法等待所有任务完成。

   executor.shutdown();
   try {
       if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
           executor.shutdownNow(); // 如果在指定时间内没有完成，则强制关闭
       }
   } catch (InterruptedException e) {
       executor.shutdownNow();
   }
   

4. 使用Semaphore进行并发控制： 如果你需要更细粒度的并发控制，可以使用Semaphore类。Semaphore可以限制同时访问特定资源的线程数量。

   Semaphore semaphore = new Semaphore(3); // 允许最多3个线程同时访问
   for (int i = 0; i < 10; i++) {
       final int taskNumber = i;
       executor.submit(() -> {
           try {
               semaphore.acquire(); // 获取许可
               System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
               // 执行任务逻辑
           } catch (InterruptedException e) {
               Thread.currentThread().interrupt();
           } finally {
               semaphore.release(); // 释放许可
           }
       });
   }
   

通过这些方法，你可以使用ExecutorService来实现并发控制，确保你的应用程序能够高效地利用多线程环境。