Java ExecutorService如何限制并发任务数量

在Java中，ExecutorService是一个用于管理线程池和执行异步任务的接口。要限制并发任务数量，你可以使用Executors工具类创建一个固定大小的线程池。这样，线程池中的线程数量将保持恒定，从而限制并发任务的数量。

以下是如何使用Executors创建一个固定大小的线程池的示例：

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

public class Main {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池，限制并发任务数量为5
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 提交10个任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executorService.submit(() -> {
                System.out.println("Task " + taskId + " is running on thread " + Thread.currentThread().getName());
                try {
                    Thread.sleep(1000); // 模拟任务执行时间
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + taskId + " is completed");
            });
        }

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

在这个示例中，我们创建了一个固定大小为5的线程池。这意味着最多只能有5个任务同时运行。当我们提交10个任务时，它们将被放入队列中等待，直到有线程可用。

注意，在使用完ExecutorService后，应该调用shutdown()方法来关闭它。这将阻止新任务提交到线程池，并允许当前正在运行的任务完成。