如何高效实现ExecutorService的待执行任务取消（不中断已启动任务）

这个需求其实挺常见的——既要拒绝新任务提交，又不想打断已经在运行的任务，只把排队等着的待执行任务取消掉对吧？我来给你拆解一下具体的实现思路和代码：

核心思路拆解 #

你想要的效果其实是三个动作的组合：

• 第一步：拒绝新任务：调用shutdown()，这样ExecutorService就不会再接受任何新的任务提交了。
• 第二步：取消待执行任务：从线程池的任务队列里取出所有还没开始执行的任务，逐个取消它们（注意不能用shutdownNow()，因为它会中断正在运行的任务）。
• 第三步：等待正在运行的任务完成：调用awaitTermination()，直到所有已经启动的任务都执行完毕。

具体代码实现 #

下面是一个可直接参考的代码示例，以最常用的ThreadPoolExecutor为例：

ExecutorService executor = new ThreadPoolExecutor(4, 8, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(100));

// 1. 先拒绝新任务提交
executor.shutdown();

// 2. 取消队列中所有待执行的任务
if (executor instanceof ThreadPoolExecutor) {
    ThreadPoolExecutor threadPool = (ThreadPoolExecutor) executor;
    Queue<Runnable> pendingQueue = threadPool.getQueue();
    
    // 遍历队列里的任务，逐个取消（仅取消未启动的）
    for (Runnable task : pendingQueue) {
        // 队列中的任务实际是RunnableFuture，可以强转为Future来调用cancel
        if (task instanceof Future<?>) {
            // 传入false：不中断已启动的任务，仅取消未启动的
            boolean isCancelled = ((Future<?>) task).cancel(false);
            // 可以根据需要记录日志，比如哪些任务被成功取消了
            if (isCancelled) {
                System.out.println("待执行任务已取消：" + task.toString());
            }
        }
    }
}

// 3. 等待所有正在运行的任务执行完毕
try {
    // 设置一个合理的超时时间，这里用1小时作为示例，你可以根据业务调整
    while (!executor.awaitTermination(1, TimeUnit.HOURS)) {
        // 超时未完成时可以打个日志，监控进度
        System.out.println("仍有任务在执行中，继续等待...");
    }
    System.out.println("所有已启动任务均执行完成");
} catch (InterruptedException e) {
    // 处理等待过程中的中断，恢复线程的中断状态
    Thread.currentThread().interrupt();
    System.out.println("等待任务完成的过程被中断，提前退出");
}

关键细节说明 #

1. 为什么用cancel(false)？
   cancel(false)的行为正好匹配你的需求：如果任务还没开始执行，就会被直接取消；如果任务已经在运行了，这个调用不会中断它，只会返回false，完全不会影响正在执行的任务。

2. 关于线程池类型的兼容
   上面的代码针对ThreadPoolExecutor（Java中最常用的线程池实现），如果你的ExecutorService是其他类型（比如ForkJoinPool），获取待执行任务队列的方式会略有不同，但核心逻辑一致：拿到待执行任务的集合，逐个调用cancel(false)。

3. 队列遍历的安全性
   调用shutdown()之后，线程池不会再往队列里添加新任务，所以遍历队列时不会出现并发添加的问题。即使线程池正在从队列中取任务执行，此时调用cancel(false)对已经启动的任务也没有影响，不用担心会打断正在运行的任务。

备注：内容来源于stack exchange，提问作者queeg