如何使用Java ExecutorService控制并发数

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方法。通过使用ExecutorService，你可以控制并发执行的任务数量。以下是如何使用ExecutorService来控制并发数的步骤：

1. 创建一个线程池：首先，你需要创建一个ExecutorService实例。通常，这可以通过调用Executors类的静态工厂方法来完成，例如Executors.newFixedThreadPool(int nThreads)来创建一个固定大小的线程池。

2. 提交任务：然后，你可以向ExecutorService提交任务。这些任务可以是实现了Runnable接口的对象，或者是实现了Callable接口的对象。

3. 控制并发数：线程池的大小决定了可以同时执行的任务数量。如果你创建了一个固定大小的线程池，那么这个大小就是并发数的上限。

4. 关闭线程池：当你不再需要线程池时，应该调用shutdown()方法来优雅地关闭它。这将阻止新任务被接受，并允许当前正在执行的任务完成。

下面是一个简单的例子，展示了如何使用ExecutorService来控制并发数：

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

public class ThreadPoolExample {

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

        // 提交10个任务
        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            executorService.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");
            });
        }

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

在这个例子中，我们创建了一个可以同时运行5个任务的线程池。即使我们提交了10个任务，也只有5个任务会同时运行。其他的任务将会等待，直到有线程可用。

请注意，shutdown()方法并不会立即停止所有正在执行的任务。如果你需要立即停止所有任务，可以使用shutdownNow()方法，但这通常不是推荐的做法，因为它可能会导致任务被突然中断，而不是优雅地完成它们的工作。