Java：如何在Future任务执行失败时终止所有线程？

要实现「单个任务失败即终止所有活跃线程、停止提交新任务」的需求，核心是原子化监控任务失败状态+线程池强制终止+任务响应中断，以下是具体实现方案：

核心思路 #

1. 用原子布尔值标记任务失败状态，避免多线程下的竞态问题；
2. 每个任务执行时先检查失败状态，若已失败则直接中断自身；
3. 任务捕获到异常时，原子性设置失败标志，并触发线程池的shutdownNow()操作；
4. 遍历提交任务的循环中，每次提交前检查失败标志，若已失败则退出循环。

代码实现 #

1. 线程池提交任务逻辑 #

import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicBoolean;

// 初始化原子失败标志
AtomicBoolean taskFailed = new AtomicBoolean(false);
// 你的线程池实例（根据实际需求配置核心线程数、队列等）
ExecutorService threadPoolExecutor = new ThreadPoolExecutor(
        5,
        10,
        60L,
        TimeUnit.SECONDS,
        new ArrayBlockingQueue<>(100)
);

for (BusinessElement el : elements) {
    // 若已有任务失败，立即停止提交新任务
    if (taskFailed.get()) {
        break;
    }
    
    threadPoolExecutor.submit(() -> {
        // 任务执行前先检查失败状态，避免无效执行
        if (taskFailed.get()) {
            Thread.currentThread().interrupt();
            return;
        }
        
        try {
            // 执行数据库写入操作
            createElement(el);
        } catch (Exception e) {
            // 原子性设置失败标志，确保只有第一个失败任务触发终止
            if (taskFailed.compareAndSet(false, true)) {
                // 强制终止线程池：中断所有活跃线程，清空待执行任务队列
                threadPoolExecutor.shutdownNow();
                System.err.println("任务执行失败，终止所有线程: " + e.getMessage());
            }
            // 重新抛出异常，便于后续监控（可选）
            throw e;
        }
    });
}

2. 数据库写入方法（需响应中断） #

shutdownNow()通过发送中断信号终止线程，因此createElement方法需要主动响应中断：

private void createElement(BusinessElement el) throws Exception {
    // 关键步骤前检查中断状态
    if (Thread.currentThread().isInterrupted()) {
        throw new InterruptedException("任务被中断");
    }
    
    // 数据库操作示例（JDBC）
    try (Connection conn = getDatabaseConnection()) {
        String insertSql = "INSERT INTO business_table (id, name) VALUES (?, ?)";
        try (PreparedStatement stmt = conn.prepareStatement(insertSql)) {
            stmt.setString(1, el.getId());
            stmt.setString(2, el.getName());
            
            // 执行前再次检查中断
            if (Thread.currentThread().isInterrupted()) {
                throw new InterruptedException("任务被中断");
            }
            
            stmt.executeUpdate();
        }
    } catch (InterruptedException e) {
        // 重置中断状态，确保上层能感知到中断
        Thread.currentThread().interrupt();
        throw e;
    }
}

关键注意事项 #

• 原子标志位的必要性：AtomicBoolean保证了多线程环境下「失败状态设置」的原子性，避免多个任务同时触发shutdownNow()。
• 任务必须响应中断：如果createElement中有不响应中断的阻塞操作（如某些第三方IO库），需额外处理（比如设置超时时间、主动终止资源），否则shutdownNow()无法终止该任务。
• shutdownNow()的行为：该方法会将线程池置为STOP状态，拒绝新任务提交，中断所有正在执行的线程，并返回队列中未执行的任务列表。

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