线程池未关闭会导致jvm无法退出和rejectedexecutionexception异常;应先调用shutdown()再配合awaittermination()等待终止,超时后可shutdownnow();推荐使用autocloseable封装或spring的destroymethod自动管理。

线程池未关闭导致的资源泄漏现象
Java中线程池本身不会自动释放线程,ThreadPoolExecutor 创建的非守护线程会阻止JVM退出;常见表现是应用停止后进程仍在运行,或重启时抛出 java.util.concurrent.RejectedExecutionException: Task java.lang.Runnable rejected from java.util.concurrent.ThreadPoolExecutor@... —— 本质是旧线程池还在接收任务,而新实例已初始化。
shutdown() 和 shutdownNow() 的关键区别
两者都用于终止线程池,但行为完全不同:
-
shutdown():平滑关闭,不再接受新任务,但会等待已提交任务(包括队列中未执行的)完成;适合常规服务停机场景 -
shutdownNow():立即尝试中断所有正在执行的线程,并返回尚未执行的任务列表;不保证任务一定被取消,尤其对忽略中断的代码无效
错误做法是只调用 shutdown() 就结束,却不等待任务真正结束——这会导致主线程退出、JVM终止,而工作线程仍在后台运行(尤其当使用 Executors.newFixedThreadPool() 这类默认创建非守护线程的工厂时)。
必须配合 awaitTermination() 的典型模式
仅调用 shutdown() 或 shutdownNow() 不足以确保资源释放。正确做法是:
立即学习“Java免费学习笔记(深入)”;
- 先调用
shutdown() - 再用
awaitTermination(long timeout, TimeUnit unit)等待指定时间 - 超时后若仍为
!isTerminated(),可考虑记录告警或强制shutdownNow()
示例片段:
executor.shutdown();
try {
if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
executor.shutdownNow();
if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
System.err.println("线程池未能正常终止");
}
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
使用 try-with-resources 或 Spring 生命周期管理更可靠
手动调用关闭逻辑容易遗漏(比如异常提前跳出)。更稳妥的方式:
- 自定义线程池包装类实现
AutoCloseable,在close()中执行完整关闭流程 - 在Spring环境中,优先使用
@Bean(destroyMethod = "shutdown")声明线程池,由容器托管生命周期 - 避免在工具类中用静态
ExecutorService,除非明确设计为全局长周期使用且有统一关闭入口
特别注意:Executors.newCachedThreadPool() 创建的线程默认60秒空闲后销毁,看似“自动回收”,但若任务持续提交,线程数可能无限增长;且其线程仍是非守护线程,JVM退出前仍需显式关闭。









