Java ExecutorService如何优雅地关闭

在Java中，优雅地关闭ExecutorService可以通过以下步骤实现：

1. 调用shutdown()方法：这将启动一个有序的关闭过程，在此过程中，ExecutorService将停止接受新的任务，但会继续执行已经提交的任务。shutdown()方法返回一个布尔值，表示是否成功启动了关闭过程。

executorService.shutdown();

2. 等待已提交的任务完成：可以使用shutdownNow()方法和awaitTermination()方法来等待已提交的任务完成。shutdownNow()方法尝试立即停止所有正在执行的任务，并返回一个包含尚未开始执行的任务列表。awaitTermination()方法会阻塞，直到所有任务完成或者超时发生。

boolean isTerminated = executorService.awaitTermination(long timeout, TimeUnit unit);

其中，timeout参数表示等待的最长时间，unit参数表示时间的单位（如：TimeUnit.SECONDS）。

3. 处理未完成的任务：如果有未完成的任务，可以根据实际需求进行处理，例如记录日志、发送通知等。

4. 关闭线程池：如果需要完全关闭线程池，可以调用shutdownNow()方法。这将尝试停止所有正在执行的任务，并返回一个包含尚未开始执行的任务列表。

List<Runnable> remainingTasks = executorService.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++) {
            executorService.submit(() -> {
                try {
                    System.out.println("Task started: " + Thread.currentThread().getName());
                    Thread.sleep(2000);
                    System.out.println("Task completed: " + Thread.currentThread().getName());
                } catch (InterruptedException e) {
                    System.out.println("Task interrupted: " + Thread.currentThread().getName());
                }
            });
        }

        // 优雅地关闭线程池
        executorService.shutdown();
        try {
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }

        System.out.println("ExecutorService has been shut down gracefully.");
    }
}

在这个示例中，我们创建了一个固定大小的线程池，并提交了10个任务。然后，我们调用shutdown()方法启动有序关闭过程，并使用awaitTermination()方法等待任务完成。如果在指定的时间内（这里是60秒）任务没有完成，我们将调用shutdownNow()方法强制关闭线程池。