Java ExecutorService区分shutdown与shutdownNow的退出策略

Java 线程池下线时，真正需要区分的不是“关得温和还是强硬”，而是任务现在处于哪里、是否允许完成，以及任务能不能响应中断。shutdown() 会拒绝新任务，但让已经提交的任务继续执行；shutdownNow() 会尝试中断执行中的任务，并返回尚未开始的任务，但它不保证正在运行的任务立刻停止。正常服务下线应先优雅等待，超时后再升级为尽力中断。

一、先划清两种退出语义

可以把线程池看成三组对象：等待队列里的任务、正在执行的任务，以及准备继续提交任务的调用方。调用 shutdown() 后，第三组先被封口，前两组按原计划收尾；调用 shutdownNow() 后，等待队列会被排空并以返回列表交给调用方，执行中的任务收到中断请求。

这个差异决定了它们的适用力：可重试的后台任务可以在超时后丢回队列或记录补偿；带外部副作用的写入任务，通常更适合先给出完成窗口，而不是直接调用 shutdownNow()。

二、用两阶段策略实现优雅退出

Oracle 文档给出的思路是两阶段关闭：先阻止新任务进入，等待已有任务；等待超时后再尝试取消。下面的辅助方法保留了调用线程的中断状态，也把第二次等待单独留下来，避免把“发出停止请求”误判为“已经停止”。

static void closeExecutor(ExecutorService pool) {
    pool.shutdown(); // 先封口：不再接受新任务，让已提交任务正常收尾
    try {
        if (!pool.awaitTermination(30, TimeUnit.SECONDS)) {
            List neverStarted = pool.shutdownNow(); // 超时后请求中断，并取回未启动任务
            logDroppedTasks(neverStarted); // 记录可重试任务，避免静默丢失
            if (!pool.awaitTermination(30, TimeUnit.SECONDS)) {
                log.warn("executor still running"); // 这里只能记录异常，不能假装已经退出
            }
        }
    } catch (InterruptedException ex) {
        pool.shutdownNow(); // 下线线程本身被打断时，优先收紧任务范围
        Thread.currentThread().interrupt(); // 恢复调用线程的中断语义，交给上层决定后续动作
    }
}

shutdown() 本身不等待任务结束，shutdownNow() 也不等待执行中任务结束；是否完成要看 awaitTermination() 的返回值，最终状态则以 isTerminated() 为准。

三、让任务真正响应中断

线程池只能发出中断请求，任务代码必须配合。可中断的阻塞调用通常会抛出 InterruptedException；轮询型任务则应主动检查 Thread.currentThread().isInterrupted()。捕获异常后直接忽略，会让上层继续以为任务应该运行，导致第二次等待仍然超时。

void consume(BlockingQueue queue) {
    try {
        while (!Thread.currentThread().isInterrupted()) { // 每轮先检查关闭信号
            Job job = queue.take(); // take 被中断时会抛出 InterruptedException
            handle(job); // 业务处理应保持可重试或具备幂等边界
        }
    } catch (InterruptedException ex) {
        Thread.currentThread().interrupt(); // 不吞掉中断，让执行器和上层都能观察到取消
        cleanupLocalState(); // 释放本地资源后返回，不在这里重新提交任务
    }
}

如果任务正在执行不可中断的外部调用，shutdownNow() 不能替你终止它。此时应缩短外部调用超时、把取消信号传入客户端，或把任务设计成可恢复步骤；不要把“线程还没退出”简单归因于 ExecutorService 失效。

四、按任务类型选择退出方案

架构上可以把退出策略写进任务分类，而不是写进某个异常分支。批量导入、报表生成等可重试任务，适合“先 shutdown，超时后取回未启动任务并补偿”；HTTP 请求转发等有明确截止时间的任务，适合较短等待窗口后升级；扣款、库存扣减等外部副作用任务，则应优先保证幂等和落库状态，再决定是否允许中断。

五、收尾时核对这份清单

• 入口是否已经拒绝新任务，而不是仍有代码提交到旧线程池。
• shutdownNow() 返回的任务是否有重试、补偿或人工处理路径。
• 任务是否恢复中断标志，资源是否在退出路径释放。
• awaitTermination() 超时后是否记录了线程池仍在运行，而不是直接打印成功。
• 只有 isTerminated() 为 true，才把线程池视为完全退出。

相关问题

shutdownNow 会杀死正在运行的线程吗？不会。它通常通过 Thread.interrupt() 尝试停止任务；任务若忽略中断或卡在不可中断操作中，仍可能继续运行。

为什么 shutdown 后服务还是没有退出？因为它只拒绝新任务，不等待已有任务。需要使用 awaitTermination()，并检查任务是否正确处理了中断与外部依赖超时。