java ExecutorService如何实现优雅的关闭

在Java中，使用ExecutorService时，优雅地关闭线程池可以确保正在执行的任务能够完成，同时避免新任务被提交。以下是几种优雅关闭ExecutorService的方法：

1. 使用 shutdown() 方法

shutdown()方法会启动线程池的关闭过程，不再接受新的任务，但会等待已经提交的任务完成。

ExecutorService executorService = Executors.newFixedThreadPool(10);
// 提交任务
executorService.submit(() -> {
    // 任务逻辑
});

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

2. 使用 shutdownNow() 方法

shutdownNow()方法会尝试立即停止所有正在执行的任务，并返回一个等待执行的任务列表。这个方法通常用于紧急情况，因为它可能会导致任务被中断。

ExecutorService executorService = Executors.newFixedThreadPool(10);
// 提交任务
executorService.submit(() -> {
    // 任务逻辑
});

// 立即关闭线程池
List<Runnable> remainingTasks = executorService.shutdownNow();

3. 使用 awaitTermination() 方法

awaitTermination()方法可以用来等待线程池中的任务完成。你可以指定一个超时时间，如果在指定时间内任务没有完成，可以采取进一步的措施。

ExecutorService executorService = Executors.newFixedThreadPool(10);
// 提交任务
executorService.submit(() -> {
    // 任务逻辑
});

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

try {
    // 等待最多10秒，直到所有任务完成
    if (!executorService.awaitTermination(10, TimeUnit.SECONDS)) {
        // 如果10秒内没有完成，可以采取进一步的措施
        System.out.println("线程池没有在指定时间内关闭");
    }
} catch (InterruptedException e) {
    // 如果当前线程被中断，可以采取进一步的措施
    System.out.println("线程池关闭过程中被中断");
}

4. 结合使用 shutdown() 和 awaitTermination()

通常情况下，结合使用shutdown()和awaitTermination()是最优雅的方式。

ExecutorService executorService = Executors.newFixedThreadPool(10);
// 提交任务
executorService.submit(() -> {
    // 任务逻辑
});

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

try {
    // 等待最多60秒，直到所有任务完成
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        // 如果60秒内没有完成，可以采取进一步的措施
        System.out.println("线程池没有在指定时间内关闭");
        // 可以选择再次尝试关闭
        if (!executorService.shutdownNow().isEmpty()) {
            System.out.println("强制关闭线程池成功");
        }
    }
} catch (InterruptedException e) {
    // 如果当前线程被中断，可以采取进一步的措施
    System.out.println("线程池关闭过程中被中断");
    // 中断正在执行的任务
    executorService.shutdownNow();
}

通过这些方法，你可以确保ExecutorService在关闭时能够优雅地处理正在执行的任务，并且不会导致资源泄漏或其他问题。