如何使用java ExecutorService进行并发控制

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

1. 导入所需的包：

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

2. 创建一个ExecutorService实例：

int numberOfThreads = 5; // 你想要并发执行的任务数量
ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);

这里，我们创建了一个固定大小的线程池，它可以同时运行5个任务。你可以根据需要调整numberOfThreads的值。

3. 提交任务给ExecutorService：

for (int i = 0; i < 10; i++) {
    Runnable task = new MyTask(i);
    executorService.submit(task);
}

这里，我们提交了10个任务给ExecutorService。每个任务都是MyTask类的一个实例，它实现了Runnable接口。

4. 关闭ExecutorService：

在所有任务都提交给ExecutorService之后，你需要关闭它，以便释放系统资源。这可以通过调用shutdown()方法来实现：

executorService.shutdown();

shutdown()方法会等待所有已提交的任务完成执行，然后关闭线程池。

5. （可选）等待ExecutorService中的任务完成：

如果你需要在程序结束前等待所有任务完成，可以使用awaitTermination()方法：

try {
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        executorService.shutdownNow(); // 如果在60秒内没有完成任务，强制关闭线程池
    }
} catch (InterruptedException e) {
    executorService.shutdownNow(); // 如果当前线程被中断，强制关闭线程池
}

这个例子中，我们等待所有任务在60秒内完成。如果在这段时间内没有完成任务，我们将强制关闭线程池。

总结一下，使用ExecutorService进行并发控制的步骤包括：创建ExecutorService实例，提交任务，关闭ExecutorService，以及等待任务完成。这样可以有效地控制并发任务的数量，避免创建过多的线程。