ExecutorService如何限制并发任务数量

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

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

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 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个任务同时运行。当所有任务都提交到线程池后，它们将被分配给线程池中的线程。一旦有线程完成任务，它将立即开始执行下一个任务，直到所有任务都完成。

请注意，在实际应用中，您可能需要根据系统资源和任务特性来调整线程池的大小。过大的线程池可能导致资源竞争和性能下降，而过小的线程池可能导致任务排队等待，从而降低整体吞吐量。