如何利用Java ExecutorService实现并发控制

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给执行的机制，同时隐藏了线程创建和管理的复杂性。通过使用ExecutorService，你可以更容易地实现并发控制，管理线程池，并控制任务的执行。

以下是使用ExecutorService实现并发控制的一些基本步骤：

1. 创建线程池：

   • 使用Executors类的静态方法来创建不同类型的线程池，例如固定大小的线程池、缓存线程池或单线程执行器。
   • 例如，创建一个固定大小的线程池：ExecutorService executor = Executors.newFixedThreadPool(10);

2. 提交任务：

   • 使用execute(Runnable)方法提交一个实现了Runnable接口的任务。
   • 或者使用submit(Callable<T>)方法提交一个实现了Callable<T>接口的任务，该方法返回一个Future<T>对象，可以用来获取任务的执行结果。
   • 例如：executor.submit(new MyTask());

3. 控制并发：

   • 线程池的大小决定了可以同时执行的任务数量。例如，一个大小为10的线程池最多可以同时执行10个任务。
   • 如果需要更细粒度的控制，可以使用Semaphore来限制同时访问特定资源的任务数量。

4. 关闭线程池：

   • 当不再需要线程池时，应该调用shutdown()方法来优雅地关闭它。这将停止接受新的任务，并等待已经提交的任务完成。
   • 如果需要立即关闭线程池，可以使用shutdownNow()方法，但这可能会导致正在执行的任务被中断。
   • 例如：executor.shutdown();

5. 处理任务结果：

   • 如果使用submit()方法提交了Callable任务，可以通过返回的Future对象来获取任务的执行结果或检查任务是否完成。
   • 例如：Future<String> future = executor.submit(new MyCallableTask()); String result = future.get();

下面是一个简单的示例，展示了如何使用ExecutorService来并发执行多个任务：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ConcurrentControlExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

        // 提交10个任务
        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());
                // 模拟任务执行时间
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println("Task " + taskNumber + " is completed");
            });
        }

        // 关闭线程池
        executor.shutdown();
    }
}

在这个示例中，我们创建了一个大小为5的线程池，并提交了10个任务。由于线程池的大小限制，这些任务将被并发执行，但同时运行的任务不会超过5个。