在Java里如何在多线程中处理异常_Java线程异常管理说明_技术教程

Java子线程未捕获异常默认静默丢失，需通过setUncaughtExceptionHandler、Callable+Future.get()或CompletableFuture.handle()等显式处理，否则异常无法被感知。

Java线程中未捕获异常会直接丢失

主线程抛出未捕获异常会终止JVM，但子线程不会——Thread默认把未捕获异常吞掉，连日志都不打。你看到线程静默退出、任务莫名中断，大概率是这个原因。

每个Thread对象内部持有UncaughtExceptionHandler，默认是ThreadGroup的实现，它只调用System.err.println，且在很多容器或测试环境里被重定向或忽略
ExecutorService提交的Runnable更危险：异常彻底消失，Future.get()
不抛异常（因为Runnable没有返回值），你根本收不到信号
用Callable + Future能捕获异常，但必须显式调用future.get()，否则照样“看不见”

设置线程级未捕获异常处理器

对单个线程，用setUncaughtExceptionHandler是最直接的方式，尤其适合手动创建Thread的场景。

Thread thread = new Thread(() -> {
    throw new RuntimeException("boom");
});
thread.setUncaughtExceptionHandler((t, e) -> {
    System.err.println("线程 [" + t.getName() + "] 异常: " + e.getMessage());
    // 这里可以发告警、记录到ELK、触发降级逻辑
});
thread.start();

处理器只对当前线程生效，不能跨线程继承；新线程需单独设置
如果线程已启动再调用setUncaughtExceptionHandler，无效
避免在处理器里做耗时操作（如远程调用），可能阻塞JVM shutdown hook

ExecutorService中正确处理Callable异常

用Callable替代Runnable，才能把异常“带出来”。关键不是提交，而是消费——Future.get()才是异常出口。

ExecutorService exec = Executors.newFixedThreadPool(2);
Future future = exec.submit(() -> {
    if (Math.random() > 0.5) throw new RuntimeException("task failed");
    return "ok";
});

try {
    String result = future.get(); // ← 异常在此处抛出
} catch (ExecutionException e) {
    Throwable cause = e.getCause(); // ← 真正的业务异常在这里
    System.err.println("任务异常: " + cause.getClass().getSimpleName());
}
exec.shutdown();

ExecutionException是包装器，必须用e.getCause()拿到原始异常
future.get(5, TimeUnit.SECONDS)带超时更安全，避免无限等待
别忘了shutdown()或shutdownNow()，否则线程池不释放

ForkJoinPool和CompletableFuture的异常差异

ForkJoinPool（包括commonPool）默认不传播异常；CompletableFuture则依赖回调链，异常处理方式完全不同。

ForkJoinTask的get()会抛ExecutionException，但invoke()静默失败——务必用get()
CompletableFuture.supplyAsync(...)若没接exceptionally()或handle()，异常会丢失；join()才抛CompletionException
CompletableFuture.allOf()遇到任一异常就停止，但不会暴露哪个子任务失败——要用allOf(futures).thenApply(v -> ...)配合每个future.handle()分别捕获