在Java中如何处理多线程中的异常_Java并发异常处理思路解析_技术教程

未捕获异常默认静默终止线程且不传播；可通过Future.get()捕获ExecutionException、重写ThreadPoolExecutor.afterExecute统一处理，或利用ForkJoinPool异常合并机制。

未捕获的异常会直接终止线程，且默认不传播

Java 中，Thread 执行过程中抛出的未捕获异常（即未在 run() 内用 try-catch 捕获的 RuntimeException 或 Error），不会中断其他线程，也不会向上抛给启动它的线程，而是静默终止该线程，并触发其 UncaughtExceptionHandler。默认情况下，这个处理器只是打印堆栈到 System.err，**完全不会通知主线程或影响程序流程**。

这意味着：你用 ExecutorService 提交了 10 个任务，其中第 3 个因空指针崩溃，其余 9 个照常运行，而你可能根本不知道第 3 个失败了——除非你主动检查或监听。

每个 Thread 都有独立的 UncaughtExceptionHandler，可通过 setUncaughtExceptionHandler() 设置
Thread.setDefaultUncaughtExceptionHandler() 只影响未显式设置 handler 的线程，对 ExecutorService 创建的线程无效（因为线程池通常会覆盖它）
Future.get() 能捕获任务中抛出的异常，但前提是任务是通过 submit() 提交的 Callable；execute(Runnable) 的异常永远无法通过 Future 获取

使用 Callable + Future 获取可检查的异常结果

这是最可控的方式：把逻辑包装进 Callable，用 ExecutorService.submit() 提交，再调用 Future.get()。此时，任务内抛出的任何异常（包括 RuntimeException）都会被封装为 ExecutionE

xception，其 getCause() 返回原始异常。

ExecutorService exec = Executors.newFixedThreadPool(2);
Future future = exec.submit(() -> {
    if (Math.random() > 0.5) throw new IllegalArgumentException("随机失败");
    return "success";
});

try {
    String result = future.get(); // 正常返回，或抛 ExecutionException
} catch (ExecutionException e) {
    Throwable cause = e.getCause(); // ← 这里是原始 IllegalArgumentException
    System.err.println("任务失败：" + cause.getMessage());
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}
exec.shutdown();

Runnable 无法返回值、也无法让 get() 抛出原始异常，务必改用 Callable
future.get() 是阻塞的，如需非阻塞检查，可用 isDone() + isCancelled() + get(0, TimeUnit.NANOSECONDS)
若任务已超时或被取消，get() 会分别抛 TimeoutException 或 CancellationException，注意区分处理

自定义 ThreadPoolExecutor 并重写 afterExecute

如果你用的是 ThreadPoolExecutor（包括 Executors 工厂创建的实例），可以继承它并重写 afterExecute(Runnable r, Throwable t) 方法。该方法在每个任务执行结束后被调用，无论成功还是异常，参数 t 就是未捕获的异常（null 表示正常结束）。

ThreadPoolExecutor executor = new ThreadPoolExecutor(
    2, 2, 0L, TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<>()) {
    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        super.afterExecute(r, t);
        if (t != null) {
            System.err.println("线程池中任务异常：" + t);
            // 可记录日志、上报监控、触发告警等
        }
    }
};

此方式能统一捕获所有类型任务（Runnable 和 Callable）的未捕获异常
注意：如果任务是 Callable 且异常已被 Future.get() 拿走，则 t 为 null；只有未被 get() 消费的异常才会传入这里
不要在 afterExecute 中做耗时操作（如网络请求），否则会阻塞线程池的工作线程

ForkJoinPool 的异常传播机制特殊

ForkJoinPool 对异常的处理和其他线程池不同：它会将子任务的异常“向上合并”，最终在 invoke() 或 join() 时集中抛出。但要注意，只有第一个异常会被保留，后续异常会被丢弃；且 RecursiveAction（无返回值）的异常无法通过 join() 获取，必须用 getRawResult() 配合状态检查，或改用 RecursiveTask。