生产环境线程池必须调用shutdown()停止接收新任务，再用awaitTermination()配合超时与volatile变量保护实现优雅关闭，超时后可选shutdownNow()强制终止。
生产环境线程池必须确保任务执行完毕后再彻底关闭，否则可能丢失任务或引发资源泄漏。核心在于正确使用 shutdown() 和 awaitTermination(long, TimeUnit)，并用变量保护避免重复调用或状态误判。
shutdown() 仅发信号，不阻塞
shutdown() 的作用是停止接收新任务，将线程池状态设为 SHUTDOWN，但已提交的任务（包括队列中等待的）仍会继续执行。它不等待、不中断、不抛异常，调用后立即返回。
- 只能调用一次：重复调用无效果，但不应依赖此行为，建议加状态判断
- 不能和
shutdownNow()混用：两者语义冲突，shutdownNow()会尝试中断运行中任务并清空队列 - 建议配合 volatile 布尔变量标记“已发起关闭”，防止多线程重复触发
awaitTermination() 需配合超时与重试逻辑
awaitTermination() 是阻塞方法，等待所有任务完成（含队列中未开始的），但它可能因超时提前返回 false。此时线程池未必真终止，需主动判断状态并决定是否继续等待或强制终止。
- 不要写成
while (!awaitTermination(1, SECONDS)) {}：无限等待风险高，应限定最大重试次数或总等待时长 - 每次超时后检查
isTerminated()：若返回 true，说明已自然结束；否则可记录日志或触发降级动作 - 超时后可选
shutdownNow()强制终止，但要确保任务支持中断（如响应Thread.interrupted()）
用 volatile 变量保护关闭流程的原子性
多个组件（如 Spring 生命周期、HTTP 关闭钩子、JVM Shutdown Hook）可能同时触发关闭逻辑，需用变量防止重复 shutdown 或 awaitTermination 被并发调用干扰。
- 定义
private volatile boolean isShuttingDown = false; - 关闭入口先 CAS 或同步块检查并设置该变量，仅当成功才执行
shutdown() -
awaitTermination()不必加锁，但其调用应严格在shutdown()之后，且不被重复执行（可用另一个volatile boolean hasAwaited控制） - Spring 环境下推荐实现
SmartLifecycle，由容器统一协调启停顺序
实际关闭模板示例（带保护与超时兜底）
以下逻辑适用于手动管理的线程池（非 Spring 托管）：
private final ThreadPoolExecutor executor = ...;
private volatile boolean isShuttingDown = false;
public void gracefulShutdown(long timeoutMs) {
if (!isShuttingDown && isShuttingDown.compareAndSet(false, true)) {
executor.shutdown();
try {
long deadline = System.currentTimeMillis() + timeoutMs;
while (!executor.awaitTermination(100, TimeUnit.MILLISECONDS)) {
if (System.currentTimeMillis() >= deadline) {
logger.warn("ThreadPool did not terminate within {}ms, forcing shutdownNow", timeoutMs);
List<Runnable> cancelledTasks = executor.shutdownNow();
logger.info("Cancelled {} pending tasks", cancelledTasks.size());
break;
}
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
logger.error("Interrupted during shutdown", e);
}
}
}
