Java多线程间异常重抛实现 现有volatile存储异常方案是否安全

你当前的方案仅在单实例串行调用process方法的场景下能满足基础功能，存在以下明显缺陷：

• 多调用场景线程安全问题：innerException是类成员变量，若多个线程同时调用process方法，不同子线程抛出的异常会互相覆盖，导致异常传递混乱，甚至出现异常丢失的情况
• 存在不必要的自定义逻辑：JDK提供的Future本身已经封装了子线程执行结果、异常的传递能力，自行维护volatile异常变量属于重复造轮子，额外增加了代码维护成本
• 最坏情况存在1秒的感知延迟：子线程抛出异常后，主线程最长需要等待1秒（await的超时时间）才能感知到异常，在部分对延迟敏感的场景下不符合预期
• 线程资源泄漏隐患：每次调用process都新建一个单线程池，执行完成后未显式关闭，会导致JVM常驻线程不断堆积，最终引发资源耗尽问题

推荐直接使用Future自带的状态检查与异常传递能力，不需要自定义跨线程异常存储变量，代码更简洁、线程安全性更高，参考实现如下：

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import lombok.extern.slf4j.Slf4j;
import static java.util.concurrent.TimeUnit.SECONDS;

@Slf4j
public class TaskProcessor {
    // 建议复用全局线程池，避免每次新建线程池的开销和资源泄漏问题
    private static final ExecutorService SINGLE_THREAD_POOL = Executors.newSingleThreadExecutor();

    public void process() {
        CountDownLatch countDownLatch = new CountDownLatch(10_000);
        Future<?> future = SINGLE_THREAD_POOL.submit(() -> {
            for (int i = 0; i < 10_000; i++) {
                // 执行业务逻辑
                countDownLatch.countDown();
            }
        });

        try {
            while (!countDownLatch.await(1, SECONDS)) {
                // 先检查子线程是否已终止（正常结束或异常退出）
                if (future.isDone()) {
                    // 调用get方法会自动抛出子线程执行时的异常（封装为ExecutionException）
                    future.get();
                    // 走到这里说明子线程正常执行完成但计数未归零，属于逻辑异常
                    throw new IllegalStateException("子线程执行完成但CountDownLatch计数未归零");
                }
                // 执行周期性任务
            }
            // 计数归零后再检查一次子线程状态，避免最后一次计数完成后子线程异常
            future.get();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } catch (Exception e) {
            log.error("任务执行失败", e);
            // 可选：主动中断子线程，避免资源浪费
            future.cancel(true);
        }
    }
}

该方案的优势如下：

• 无自定义跨线程变量，完全依赖JDK原生API实现，线程安全有保障，支持多线程并发调用process方法
• 子线程异常感知无额外延迟，每次await超时后第一时间就能检查到子线程终止状态
• 增加了逻辑异常校验，避免子线程正常结束但计数未归零导致的死循环问题
• 复用全局线程池，避免了线程资源泄漏问题

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