Java中的异常传播机制在单线程环境下逻辑清晰，被调用方法抛出的异常会沿着调用栈向上传递，直到被对应的catch块捕获。但切换到多线程场景后，每个线程都有独立的调用栈，异常的传播范围被限制在当前线程内部，不会自动传递到创建它的父线程或者其他线程中。
多线程下异常传播的基本规则
多线程环境中，线程是独立的执行单元，每个线程的异常只会在自身的执行路径中传播，不会跨线程传递。比如主线程启动了一个子线程，子线程执行过程中抛出运行时异常，这个异常只会在子线程内部抛出，主线程的try-catch块无法捕获到这个异常。
我们通过一段简单的代码来验证这个特性：
public class ThreadExceptionDemo {
public static void main(String[] args) {
// 主线程尝试捕获子线程的异常
try {
Thread childThread = new Thread(() -> {
// 子线程抛出运行时异常
throw new RuntimeException("子线程发生异常");
});
childThread.start();
} catch (RuntimeException e) {
// 这个catch块不会被执行
System.out.println("捕获到异常：" + e.getMessage());
}
}
}
运行上面的代码，你会发现主线程的catch块不会触发，控制台会直接打印子线程的异常堆栈信息，并且子线程会直接终止执行，这就是多线程异常不跨线程传播的典型表现。
常见的线程异常处理方案
1. 设置线程未捕获异常处理器
Java为Thread类提供了未捕获异常处理器机制，当线程抛出未被捕获的异常时，会回调设置的异常处理器来处理异常。我们可以通过setUncaughtExceptionHandler方法为单个线程设置处理器，也可以通过Thread.setDefaultUncaughtExceptionHandler设置所有线程的默认处理器。
示例代码如下：
public class UncaughtExceptionHandlerDemo {
public static void main(String[] args) {
// 设置默认未捕获异常处理器
Thread.setDefaultUncaughtExceptionHandler((thread, throwable) -> {
System.out.println("线程" + thread.getName() + "发生未捕获异常：" + throwable.getMessage());
// 这里可以添加日志记录、异常报警等处理逻辑
});
Thread thread1 = new Thread(() -> {
throw new RuntimeException("线程1执行异常");
}, "自定义线程1");
Thread thread2 = new Thread(() -> {
throw new RuntimeException("线程2执行异常");
}, "自定义线程2");
thread1.start();
thread2.start();
}
}
2. 使用Callable配合Future获取异常
如果需要通过线程池执行任务，并且希望获取任务的执行结果和可能抛出的异常，可以使用Callable接口代替Runnable接口，Callable的call方法可以返回执行结果，也可以抛出异常。提交Callable任务后会返回Future对象，通过Future.get()方法可以获取执行结果，如果任务执行过程中抛出异常，get方法会抛出ExecutionException，其内部的cause就是任务抛出的原始异常。
示例代码：
import java.util.concurrent.*;
public class CallableExceptionDemo {
public static void main(String[] args) {
ExecutorService executor = Executors.newSingleThreadExecutor();
// 提交Callable任务
Future<String> future = executor.submit(() -> {
if (true) {
throw new RuntimeException("Callable任务执行异常");
}
return "任务执行成功";
});
try {
// 获取任务结果，如果任务抛出异常会在这里捕获
String result = future.get();
System.out.println("任务结果：" + result);
} catch (InterruptedException e) {
System.out.println("线程被中断");
} catch (ExecutionException e) {
// 获取原始异常
Throwable originException = e.getCause();
System.out.println("捕获到任务异常：" + originException.getMessage());
} finally {
executor.shutdown();
}
}
}
3. 在任务内部自行捕获处理异常
最基础的处理方式是在Runnable或者Callable的任务逻辑内部使用try-catch块捕获异常，直接在任务执行线程内部处理异常逻辑，比如记录日志、重试执行等。这种方式适合异常不需要传递到上层线程处理的场景。
示例：
public class InnerCatchDemo {
public static void main(String[] args) {
Thread thread = new Thread(() -> {
try {
// 业务执行逻辑
int a = 1 / 0;
} catch (Exception e) {
System.out.println("任务内部捕获到异常：" + e.getMessage());
// 内部处理异常，比如记录日志、重试等
}
});
thread.start();
}
}
不同场景的异常处理选择
我们可以根据实际开发场景选择合适的处理方式：如果是需要全局监控所有线程的未捕获异常，比如记录异常日志、发送告警，优先设置默认未捕获异常处理器；如果是通过线程池执行任务，并且需要获取任务执行结果和异常，优先使用Callable配合Future的方式；如果异常只需要在任务内部处理，不需要上层感知，直接在任务内部捕获即可。
| 处理方式 | 适用场景 | 优点 |
|---|---|---|
| 未捕获异常处理器 | 全局线程异常监控、兜底异常处理 | 一次设置全局生效，不需要每个任务单独处理 |
| Callable+Future | 线程池任务结果获取、异常传递 | 可以明确获取任务执行结果和异常，适合需要上层处理异常的场景 |
| 任务内部捕获 | 异常不需要上层感知的场景 | 逻辑简单，适合独立的任务异常处理 |
理解Java多线程下的异常传播规则，选择合适的异常处理方案，可以有效避免线程异常被忽略、问题难以排查的情况，提升多线程程序的稳定性和可维护性。