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 {
    // 等待所有任务完成，最多等待1小时
    if (!executorService.awaitTermination(1, TimeUnit.HOURS)) {
        // 超时处理
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    // 中断处理
    executorService.shutdownNow();
}

4. 使用 CompletableFuture 和 ExecutorService

如果你使用 CompletableFuture 来管理异步任务，可以结合 ExecutorService 来实现优雅关闭。

ExecutorService executorService = Executors.newFixedThreadPool(10);
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
    // 任务逻辑
}, executorService);

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

try {
    // 等待任务完成
    future.get();
} catch (InterruptedException | ExecutionException e) {
    // 异常处理
    e.printStackTrace();
}

总结

• 使用 shutdown() 方法来启动关闭过程，不再接受新任务。
• 使用 awaitTermination() 方法来等待所有任务完成。
• 如果需要立即停止所有任务，可以使用 shutdownNow() 方法，但要注意处理未完成的任务。

通过这些方法，你可以确保在关闭 ExecutorService 时，所有任务都能得到妥善处理，避免资源泄漏和其他潜在问题。