未捕获异常默认静默终止线程且不传播；可通过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）都会被封装为 ExecutionException，其 getCause() 返回原始异常。
ExecutorService exec = Executors.newFixedThreadPool(2);
Future<String> 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 表示正常结束）。
立即学习“Java免费学习笔记（深入）”；
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。
- 用
RecursiveTask<T>替代RecursiveAction，确保异常能被join()捕获 -
ForkJoinTask.invoke()会同步等待并直接抛异常；fork().join()是异步提交+同步等待，效果类似 - 若想收集多个子任务的异常（而非只取第一个），需手动在每个子任务中捕获异常并聚合到结果对象中
Future.get() 主动拉取，还是靠 afterExecute 被动兜底，抑或依赖 ForkJoinTask 的自动传播——选错位置，异常就彻底丢失了。 
