Java ExecutorService 关闭后如何等待任务完成

Java 的 ExecutorService 关闭后要等待任务完成，关键不是只调用 shutdown()，而是把“拒绝新任务”和“等待终止”分成两个动作：先调用 shutdown()，再用 awaitTermination() 等待；如果超过业务允许的时间，就调用 shutdownNow() 发出中断请求，并再次等待。这样既不会让新任务继续进入队列，也不会把“已经发出停止请求”误认为“线程池已经结束”。

一、先把关闭动作和等待动作分开

shutdown() 适合正常收尾：已经提交的任务继续执行，后续提交会被拒绝，但这个调用本身立即返回。真正等待任务全部完成，要依赖 awaitTermination()。它只有在线程池已经关闭后才有明确意义，等待结果用返回值判断，而不是凭调用顺序猜测。

线程池状态可以这样理解：isShutdown() 表示是否已经收到关闭请求；isTerminated() 表示关闭后所有任务都完成。前者为 true 时，后者仍可能是 false。

二、正常场景先等待已提交任务完成

下面的收尾方法把等待时间设成一个明确的上限。第一轮等待返回 true 时，说明线程池已经终止；返回 false 时，只能说明这段时间不够，不能直接丢弃线程池引用。

static void shutdownAndAwaitTermination(ExecutorService pool) {
    pool.shutdown(); // 只拒绝新任务，让已提交任务继续收尾
    try {
        if (!pool.awaitTermination(30, TimeUnit.SECONDS)) {
            // 超时后进入兜底分支，向运行中任务发出中断请求
            List notStarted = pool.shutdownNow();
            System.err.println("未启动任务数: " + notStarted.size());
            // shutdownNow 也不等待，必须再次等待终止
            if (!pool.awaitTermination(30, TimeUnit.SECONDS)) {
                System.err.println("线程池仍未终止");
            }
        }
    } catch (InterruptedException ex) {
        // 收到上层取消时，尽力停止任务并保留中断语义
        pool.shutdownNow();
        Thread.currentThread().interrupt();
    }
}

这里的两个 30 秒只是示例上限，应该按照任务的正常耗时、服务停机窗口和未完成任务的补偿策略设定。代码没有把 shutdownNow() 当成强制杀线程：它通常通过 Thread.interrupt() 传递请求，任务是否退出仍取决于任务代码和所调用的阻塞操作。

三、超时后要处理排队任务和中断响应

shutdownNow() 会停止继续处理等待队列中的任务，并返回尚未开始执行的 Runnable 列表；对正在运行的任务则只是尝试停止。因此，返回列表适合用于日志、补偿队列或重试记录，但不等同于“这些任务已经失败”，更不能忽略其中携带的业务标识。

如果任务捕获了 InterruptedException 却不退出，或者主动清除了中断状态，第二次 awaitTermination() 仍可能超时。生产代码应让任务在循环中检查 Thread.currentThread().isInterrupted()，并在资源清理完成后结束；不要用空的 catch 把取消信号吞掉。

四、InterruptedException 不能只打印日志

awaitTermination() 被当前线程中断时会抛出 InterruptedException。常见的正确收尾是先调用 shutdownNow() 尽力取消，再调用 Thread.currentThread().interrupt() 恢复中断标记，让上层调度器、容器或调用方继续感知取消。

如果只是记录异常后返回，线程池可能继续占用工作线程；如果捕获异常后不恢复标记，上层再调用 isInterrupted() 会得到错误的未中断状态。对于必须等待清理完成的组件，可以在 finally 中集中释放资源，但不要在 finally 里无条件重新提交任务。

五、用状态检查确认“真的结束”

如果线程池仍未终止，应记录线程池名称、未启动任务数量和任务取消原因，并回到任务实现检查中断响应。不要通过不断重复调用关闭方法来“加速”终止；问题通常在任务没有配合取消，或任务持有的外部资源没有超时。

相关问题

调用 shutdown() 后还能提交任务吗？

不能。关闭请求后新的提交会被拒绝，应该在生命周期设计上把提交入口和关闭入口协调好。

shutdownNow() 会杀掉正在运行的线程吗？

不会保证强制杀线程。它通常发送中断请求，任务必须配合检查中断或正确处理可中断阻塞。

awaitTermination() 返回 false 应该怎么办？

按停机策略选择继续等待、调用 shutdownNow()，或记录未完成任务并进入补偿流程；不要把 false 当成终止成功。