Java并发中异步线程未捕获异常默认静默失败，需主动拦截：为Thread设UncaughtExceptionHandler、用Callable+Future.get()显式获取异常、用CompletableFuture.exceptionally/handle统一处理、或自定义ThreadPoolExecutor重写afterExecute记录异常。
Java 并发中，异步线程（如 Thread、ExecutorService 提交的 Runnable/Callable）抛出的未捕获异常默认不会传播到主线程，也不会自动打印日志，容易静默失败。要正确捕获并记录这些异常，关键在于**主动拦截未捕获异常**或**显式处理任务执行结果**。
为 Thread 设置 UncaughtExceptionHandler
每个 Thread 都可设置一个未捕获异常处理器，当线程因未捕获异常而终止时，JVM 会调用该处理器：
- 通过
Thread.setUncaughtExceptionHandler()为单个线程设置 - 通过
Thread.setDefaultUncaughtExceptionHandler()设置全局默认处理器（对未显式设置 handler 的线程生效） - 在 handler 中使用
Logger或slf4j记录完整堆栈，避免只打e.getMessage()
示例：
Thread thread = new Thread(() -> {
throw new RuntimeException("模拟异步异常");
});
thread.setUncaughtExceptionHandler((t, e) -> {
logger.error("线程 {} 意外终止，异常：", t.getName(), e);
});
thread.start();
用 ExecutorService 提交 Callable 而非 Runnable
Runnable 无法抛出检查异常，且异常会被吞掉；改用 Callable<T> 可将异常封装进 ExecutionException，再通过 Future.get() 显式获取：
立即学习“Java免费学习笔记（深入）”；
- 提交
Callable后必须调用future.get()（建议设超时，避免阻塞） -
get()抛出ExecutionException，其getCause()即原始异常 - 即使任务已失败，也要确保 future 被 get —— 否则异常永远不暴露
示例：
ExecutorService exec = Executors.newSingleThreadExecutor();
Future<?> future = exec.submit(() -> {
throw new IllegalArgumentException("业务校验失败");
});
try {
future.get(); // 触发异常包装与抛出
} catch (ExecutionException e) {
logger.error("异步任务执行失败", e.getCause());
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
logger.warn("等待异步结果时被中断", e);
}
使用 CompletableFuture 统一异常处理链
CompletableFuture 提供了声明式异常处理能力，推荐用于现代异步编程：
- 用
thenApplyAsync等中间操作时，异常会自动传递到后续exceptionally或handle -
exceptionally(Function<Throwable, T>)可返回兜底值，并记录日志 -
handle(BiFunction<T, Throwable, R>)同时接收结果与异常，适合统一日志+补偿逻辑
示例：
CompletableFuture.supplyAsync(() -> {
if (Math.random() > 0.5) throw new IOException("网络超时");
return "success";
}).exceptionally(e -> {
logger.error("异步调用失败", e);
return "fallback";
});
自定义 ThreadPoolExecutor 捕获任务异常
若使用线程池，可继承 ThreadPoolExecutor 并重写 afterExecute(Runnable r, Throwable t) 方法：
- 该方法在每个任务执行后被调用，
t参数即任务抛出的未捕获异常（Runnable场景下） - 注意：
t为null表示正常完成；非null才需记录 - 比全局
UncaughtExceptionHandler更精准，只针对池内任务
示例：
public class LoggingThreadPoolExecutor extends ThreadPoolExecutor {
public LoggingThreadPoolExecutor(int corePoolSize, int maxPoolSize, long keepAliveTime,
TimeUnit unit, BlockingQueue<Runnable> workQueue) {
super(corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue);
}
@Override
protected void afterExecute(Runnable r, Throwable t) {
if (t != null) {
logger.error("线程池任务执行异常", t);
}
}
}
不复杂但容易忽略：异常是否被真正“看见”，取决于你是否主动拉取或监听它。别依赖 JVM 默认行为，尤其在线程复用场景下。
