首先调用shutdown()停止接收新任务并等待已提交任务完成,再通过awaitTermination()设置超时等待;若超时或发生中断,则调用shutdownNow()强制关闭,避免资源泄漏。
在Java中安全地关闭线程池,关键在于让正在执行的任务完成,同时避免新任务提交,并妥善处理等待中的任务。直接调用 shutdownNow() 或强制中断线程可能导致数据不一致或资源泄漏。以下是推荐的步骤和最佳实践。
调用 shutdown() 方法会停止接收新任务,已提交的任务(包括队列中的)会继续执行。
• 线程池状态变为 SHUTDOWN这是安全关闭的第一步,适用于大多数场景。
shutdown() 只是开始关闭流程,不能保证线程池立刻终止。应使用 awaitTermination() 设置超时等待:
• 指定最大等待时间,例如 60 秒示例代码:
executor.shutdown();
try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 超时后尝试强制中断
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
有些任务可能忽略中断信号,导致 awaitTermination 长时间阻塞。注意以下几点:
• 在任务中定期检查 Thread.currentThread().isInterrupted()若任务阻塞在 IO 操作上,考虑使用可中断的 API(如 InterruptibleC
hannel)。
常见误区是在 finally 中无条件调用 shutdownNow(),这可能导致正在提交的任务被拒绝。正确做法是先尝试优雅关闭,仅在超时或中断时才强制关闭。
基本上就这些。关键是有序关闭、合理等待、处理中断,而不是粗暴终止。