shutdown() 和 shutdownNow() 都不会立即停掉正在运行的线程;前者温和清场、允许已提交任务完成,后者尝试中断已启动线程并返回待执行任务。

shutdown() 和 shutdownNow() 到底哪个会真正停掉线程
它们都不会“立即”停掉正在运行的线程——这是最常被误解的一点。shutdown() 是温和清场:不再接受新任务,但放行已提交的 Runnable 和队列里等着的任务;shutdownNow() 是强行中断:尝试对所有**已启动但未结束**的线程调用 Thread.interrupt(),同时把阻塞在队列里的任务全取出来返回,不执行。
关键区别不在“停不停”,而在“怎么交待后事”:
-
shutdown()适合你清楚线程内部能响应中断、或本身不阻塞(比如纯计算任务),且希望任务尽量跑完 -
shutdownNow()适合你怀疑某些任务卡死(比如没加超时的网络调用)、或进程要快速退出,愿意接受任务被截断 - 两者都**不会**等任务结束才返回,必须配合
awaitTermination(long, TimeUnit)才算真正“关到位”
awaitTermination() 怎么用才不假死
它只是“等”,不是“保证等到”——超时就直接返回 false,线程池可能还在跑。很多人写成 executor.awaitTermination(1, TimeUnit.MINUTES); 就以为万事大吉,结果发现日志里还有线程在输出,或者 JVM 拒绝退出。
正确姿势是把它放进循环里,反复检查状态:
立即学习“Java免费学习笔记(深入)”;
executor.shutdown();
try {
if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 超时后强行中断剩余线程
if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
System.err.println("线程池强制关闭失败");
}
}
} catch (InterruptedException e) {
executor.shutdownNow();
Thread.currentThread().interrupt();
}
注意三点:
- 第一次
awaitTermination()前必须先调shutdown()或shutdownNow(),否则永远等不到终止 - 中断当前线程(
Thread.currentThread().interrupt())不能省——否则上层逻辑可能丢失中断信号 - 两次等待之间没有 sleep,因为
awaitTermination()本身会阻塞,重复调用是安全的
线程不响应 interrupt 就关不干净
这是 shutdownNow() 失效的根源。如果任务里用了 Object.wait()、Thread.sleep()、BlockingQueue.take() 这类可中断阻塞,那 interrupt() 会生效并抛出 InterruptedException;但如果写的是 while 循环里手动 Thread.sleep(1000) 却没捕获异常,或者用了 LockSupport.park() 但没检查 Thread.interrupted(),那中断就石沉大海。
典型翻车场景:
- 自定义
Runnable里有无限while(!Thread.currentThread().isInterrupted()),但循环体里没做任何中断感知操作 - 用
CountDownLatch.await()却没处理InterruptedException,导致线程卡住不退出 - 第三方库的异步回调(比如老版本 Netty 的
EventLoop)没暴露 shutdown 钩子,自己关了线程池,它还在后台偷偷建新线程
解决办法只有一个:所有长期运行的逻辑,必须主动轮询 Thread.interrupted() 或捕获中断异常,并在其中做清理和 return。
常见错误现象与对应诊断点
程序退出后进程还挂着?JVM 不退出?线程 dump 显示一堆 WAITING 或 TIMED_WAITING 状态的 pool-* 线程?大概率是关得不彻底。
快速定位步骤:
- 检查是否漏掉
shutdown()/shutdownNow()—— 日志里搜shutdown关键字 - 看
awaitTermination()返回值是不是false,如果是,说明有线程没按时退出 - 用
jstack <pid>抓线程快照,重点看java.util.concurrent.ThreadPoolExecutor$Worker.run下面挂的是什么调用栈 - 确认任务代码里有没有没处理的
InterruptedException,或用了不可中断的等待(如Object.wait()但没配notify)
真正麻烦的从来不是 API 怎么调,而是你根本不知道哪些线程在暗处赖着不走。关线程池不是下命令,是跟每个线程逐个打招呼、确认离开。








