如何在ExecutorService中终止线程且不关闭执行器？

你的问题核心是不想关闭ExecutorService，但要终止当前超时分组的所有任务，shutdownNow()确实不适用，因为它会直接关停整个线程池。正确的做法是跟踪每个提交任务的Future对象，超时后单独取消这些任务。

修改后的代码示例：

ExecutorService executor = ****;
List<List<Object>> objectGroup = Lists.partition(objectList, 5);
for (List<Object> eachGroup : objectGroup ) {
    CountDownLatch latch = new CountDownLatch(eachGroup.size());
    // 新增：存储当前分组所有任务的Future
    List<Future<?>> groupFutures = new ArrayList<>();
    
    for (Object obj: eachGroup) {
        Future<?> future = executor.submit(() -> {
            try {
                doTask(obj);
            } finally {
                latch.countDown(); // 确保无论任务是否被中断，都要countDown
            }
        });
        groupFutures.add(future);
    }

    try {
        if (!latch.await(15, TimeUnit.MINUTES)) {
            // 遍历取消当前分组的所有任务
            for (Future<?> future : groupFutures) {
                // 参数true表示中断正在运行的任务
                future.cancel(true);
            }
            System.out.println("当前分组任务超时，已终止所有未完成任务");
        }
    } catch (InterruptedException e) {
        // 处理中断，比如也取消当前分组任务
        for (Future<?> future : groupFutures) {
            future.cancel(true);
        }
        Thread.currentThread().interrupt(); // 恢复中断状态
        System.out.println("等待被中断，已终止当前分组任务");
    }

}

关键注意点： #

• 任务需响应中断：doTask方法内部要正确处理中断信号。比如如果方法里有阻塞操作（如IO、sleep），要捕获InterruptedException并退出；如果是循环任务，要定期检查Thread.currentThread().isInterrupted()，及时终止执行。
• finally块确保countDown：不管任务正常完成还是被中断，都要调用latch.countDown()，避免后续分组的等待被卡住。
• cancel(true)的作用：这个方法会向任务线程发送中断信号，但任务本身必须配合响应才能真正终止，所以doTask的中断处理是关键。

这样处理后，ExecutorService可以继续接收后续分组的任务提交，只会终止当前超时分组的未完成任务，完全符合你的需求。

内容的提问来源于stack exchange，提问作者musan