关闭ExecutorService的核心是先拒绝新任务、再尽量完成已有任务、最后释放资源;应根据任务重要性与阻塞性选择shutdown()(温和等待)或shutdownNow()(立即中断),并配合awaitTermination()与异常处理确保正确终止。
关闭 ExecutorService 的核心是**先拒绝新任务,再尽量完成已有任务,最后释放资源**。直接调用 shutdown() 或 shutdownNow() 是标准做法,但具体选哪个、后续是否等待,得看业务需求。
调用 shutdown() 后,线程池不再接受新提交的任务(后续 submit() 或 execute() 会抛 RejectedExecutionException),但会继续执行已加入队列的和正在运行的任务。
awaitTermination() 使用,主动等待结束executor.shutdown();
try {
if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 超时后强制中断
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
尝试中断所有正
在执行的任务,并返回尚未执行的任务列表(从任务队列中“拔出来”)。注意:中断只是建议,能否真正停止取决于任务自身是否响应中断(比如是否检查 Thread.interrupted() 或使用可中断的阻塞方法)。
在 awaitTermination() 等待过程中可能被其他线程中断,此时应恢复中断状态并做清理。
InterruptedException 后,一般要调用 Thread.currentThread().interrupt()
catch (InterruptedException e) {}
shutdownNow() 多次调用也无额外效果基本上就这些。关键不是“怎么关”,而是“什么时候关、关到什么程度”。根据任务性质决定策略,再配合适当的等待和兜底处理。