Java ExecutorService shutdownNow 怎样处理未完成任务

Java ExecutorService.shutdownNow() 处理未完成任务时，结果不是“立刻杀死所有线程”。它会停止接收后续任务，尽力中断正在运行的任务，并把尚未开始执行的排队任务作为 List 返回；正在运行的任务是否退出，取决于任务是否正确响应中断。要确认线程池真的停下来了，还必须调用 awaitTermination()。

官方文档：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/concurrent/ExecutorService.html

工程上的稳妥做法是：先区分排队任务和运行任务，再让任务协作式退出，最后等待终止并记录无法完成的任务。

先看 shutdownNow 到底处理了哪类任务

shutdownNow() 的语义可以拆成两个结果。等待队列里的任务还没有开始执行，方法会尝试把它们取出并返回；已经被工作线程取走的任务，则只能收到中断请求。这个方法本身不会等待运行中的任务结束，也不能保证每个任务都停止。

让运行中任务真正响应中断

中断不是强制终止命令，而是线程间的协作信号。循环任务要在每轮检查 isInterrupted()；阻塞方法抛出 InterruptedException 时，不要把异常吞掉后继续循环。通常应先恢复中断状态，再从任务方法返回。资源释放放在 finally 中，避免任务退出时留下文件句柄、连接或锁。

class ImportTask implements Runnable {
    private final String jobId;

    ImportTask(String jobId) {
        this.jobId = jobId;
    }

    @Override
    public void run() {
        try {
            // 循环边界检查中断，避免收到停止信号后继续取新数据。
            while (!Thread.currentThread().isInterrupted()) {
                boolean hasMore = importOneChunk();
                if (!hasMore) {
                    break;
                }
            }
        } catch (InterruptedException ex) {
            // 阻塞方法清除中断标记，恢复它让上层和线程池都能识别取消。
            Thread.currentThread().interrupt();
        } finally {
            // 无论正常结束还是被取消，都关闭本任务持有的资源。
            closeResources(jobId);
        }
    }

    private boolean importOneChunk() throws InterruptedException {
        // 示例：真实代码在这里读取一小批数据并让阻塞调用可被中断。
        return false;
    }

    private void closeResources(String id) {
        // 示例：释放连接、文件句柄或临时锁；清理逻辑应保持幂等。
    }
}

如果任务调用的是不会响应中断的外部阻塞 I/O，shutdownNow() 也可能长期等不到终止。此时应把 I/O 超时、取消句柄和业务幂等一起设计，不能只把线程池的等待时间调大。

用两阶段关闭保证线程池真正停下来

下面的关闭顺序适合服务停止或批处理取消：先用 shutdown() 拒绝新提交；如果等待窗口内仍有任务，再用 shutdownNow() 发出中断请求；最后用 awaitTermination() 判断是否已经终止。示例把返回的排队任务交给日志或补偿队列，避免它们静默丢失。

static void stopExecutor(ExecutorService pool) {
    pool.shutdown(); // 第一阶段：不再接收新任务，让已提交任务有机会完成。
    try {
        if (!pool.awaitTermination(2, TimeUnit.SECONDS)) {
            // 第二阶段：超时后中断运行任务，并接收尚未开始的任务。
            List neverStarted = pool.shutdownNow();
            recordForRetry(neverStarted);

            // shutdownNow 不等待任务退出，这里再给中断响应留出窗口。
            if (!pool.awaitTermination(2, TimeUnit.SECONDS)) {
                recordPoolStillRunning();
            }
        }
    } catch (InterruptedException ex) {
        // 关闭线程本身也被中断时，继续发出停止请求并恢复中断状态。
        List neverStarted = pool.shutdownNow();
        recordForRetry(neverStarted);
        Thread.currentThread().interrupt();
    }
}

static void recordForRetry(List tasks) {
    // 示例：只记录可重建的业务任务标识，避免直接序列化线程对象。
}

static void recordPoolStillRunning() {
    // 示例：告警并保留现场，不能把超时误报成已完成。
}

如果业务明确要求“立即取消”，可以直接调用 shutdownNow()，但仍然要调用 awaitTermination()。返回的 List 只是“从未开始执行”的候选，不代表所有未完成工作都在里面。

重试、幂等与终止判断的检查清单

• 给每个任务携带业务 ID，记录它是排队未启动、运行中被中断，还是已经完成。
• 重试前确认写入、发送或扣减操作具备幂等键；不要把同一个 Runnable 对象直接跨线程池复用。
• 用 isShutdown() 判断是否已发出关闭请求，用 isTerminated() 判断所有任务是否结束；只看前者不够。
• 如果任务捕获 InterruptedException 后继续工作，线程池可能一直处于 terminating 状态，应优先修复任务协作逻辑。

常见问题

shutdownNow 返回为空，是不是没有未完成任务？不一定。它只返回调用瞬间尚未开始执行的排队任务，正在运行的任务不会放进这个列表。

调用 shutdownNow 后还能提交任务吗？不能。关闭请求后新提交会被拒绝；需要重试时应创建新的线程池，并重新构造可安全重试的业务任务。

为什么 awaitTermination 一直超时？常见原因是任务忽略中断、阻塞 I/O 没有超时，或清理逻辑卡住。用任务日志和 isTerminating() 定位，而不是反复调用 shutdownNow。