Java ExecutorService如何实现优雅停机

在Java中，使用ExecutorService实现优雅停机（graceful shutdown）通常涉及以下几个步骤：

1. 关闭提交新任务：首先，你需要停止向ExecutorService提交新的任务。这可以通过调用shutdown()方法来实现。

2. 等待已提交的任务完成：接下来，你需要等待所有已经提交给ExecutorService的任务完成执行。这可以通过调用awaitTermination()方法来实现。

3. 处理中断：如果在等待过程中线程被中断，你需要妥善处理中断。

4. 强制终止：如果等待时间超过了指定的超时时间，或者你需要立即终止所有任务，可以调用shutdownNow()方法来尝试停止所有正在执行的任务。

下面是一个简单的示例代码，展示了如何实现优雅停机：

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

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

        // 提交一些任务
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executorService.submit(() -> {
                try {
                    System.out.println("Task " + taskId + " started.");
                    // 模拟任务执行时间
                    Thread.sleep(1000);
                    System.out.println("Task " + taskId + " completed.");
                } catch (InterruptedException e) {
                    System.out.println("Task " + taskId + " was interrupted.");
                    Thread.currentThread().interrupt(); // 重新设置中断状态
                }
            });
        }

        // 关闭ExecutorService，不再接受新任务
        executorService.shutdown();

        try {
            // 等待所有已提交的任务完成，最多等待1小时
            if (!executorService.awaitTermination(1, TimeUnit.HOURS)) {
                // 如果在指定时间内任务没有完成，尝试强制终止
                executorService.shutdownNow();
                // 再次等待，确保所有任务都已终止
                if (!executorService.awaitTermination(1, TimeUnit.HOURS)) {
                    System.err.println("ExecutorService did not terminate");
                }
            }
        } catch (InterruptedException e) {
            // 如果当前线程被中断，尝试强制终止
            executorService.shutdownNow();
            Thread.currentThread().interrupt(); // 重新设置中断状态
        }
    }
}

在这个示例中：

• 我们创建了一个固定大小的线程池，并提交了10个任务。
• 调用shutdown()方法后，不再接受新任务。
• 使用awaitTermination()方法等待所有已提交的任务完成，最多等待1小时。
• 如果在指定时间内任务没有完成，调用shutdownNow()方法尝试强制终止所有任务。
• 再次使用awaitTermination()方法确保所有任务都已终止。

通过这种方式，你可以实现ExecutorService的优雅停机，确保所有任务在终止前有机会完成。