CompletableFuture异常不会自动向下游传播，必须显式处理；正确方式有三：1.用handle统一收口，2.用exceptionally降级，3.在thenCompose中自然延续异常链。
CompletableFuture 的异常不会自动向下游传播，必须显式处理或转发，否则会静默丢失。
异常不会自动传递到 thenApply/thenAccept 等后续阶段
当上游 CompletableFuture 因异常而完成（如调用 completeExceptionally() 或内部抛出未捕获异常），默认情况下，thenApply、thenAccept、thenCompose 这类“无异常处理能力”的方法不会执行，也不会把异常传给下游——它们 simply skip，下游 stage 保持未完成状态，直到你主动干预。
例如：
CompletableFuture<String> f1 = new CompletableFuture<>();
f1.completeExceptionally(new RuntimeException("boom"));
CompletableFuture<Integer> f2 = f1.thenApply(s -> s.length()); // 不会执行
CompletableFuture<Void> f3 = f2.thenAccept(System.out::println); // 也不会执行，f3 永远不会完成
此时 f2 和 f3 都处于“等待结果”状态，但永远不会完成——这不是 bug，是设计行为。
立即学习“Java免费学习笔记（深入）”；
正确传递异常的三种常用方式
1. 使用 handle() 统一收口：最推荐，兼顾结果和异常
- handle(BiFunction
) 接收正常结果或异常，必执行一次 - 若返回值是新 CompletableFuture，可继续链式；若需抛出异常，用 throw new CompletionException(cause) 包装（保持 CompletableFuture 异常语义）
示例：
CompletableFuture<String> f1 = CompletableFuture.failedFuture(new IOException("network"));
CompletableFuture<Integer> f2 = f1.handle((s, ex) -> {
if (ex != null) {
System.err.println("上游失败：" + ex.getMessage());
throw new CompletionException(new RuntimeException("包装后重抛", ex));
}
return s.length();
});
2. 使用 exceptionally() 单独捕获并转换异常
- 只在上游异常时触发，返回替代结果（不能抛出新异常，否则仍会丢失）
- 适合“降级”场景，比如查缓存失败就查 DB，查 DB 失败就返回默认值
示例：
CompletableFuture<String> cache = fetchFromCache();
CompletableFuture<String> fallback = cache.exceptionally(ex -> {
System.err.println("缓存失败，降级查 DB");
return fetchFromDB().join(); // 注意：这里用了 join()，实际建议用 thenCompose 避免阻塞
});
3. 在 thenCompose/thenApply 中手动 re-throw（慎用）
- 如果上游可能异常，又想在 thenXXX 中做逻辑，必须先检查是否异常完成：用 isCompletedExceptionally() 判断，再用 getNow(null) + exceptionally() 组合，但更稳妥的是直接用 handle
- 不建议在 thenApply 里 try-catch 后 throw —— 因为 thenApply 本身不处理异常，抛出会变成未捕获异常，被 ForkJoinPool 捕获并静默丢弃
组合多个异步操作时的异常链控制
用 thenCompose 替代 thenApply 做异步嵌套，能自然延续异常链：
- 如果 f1 异常，f1.thenCompose(f -> ...) 中的 lambda 根本不执行，f2 直接继承 f1 的异常
- 如果 lambda 内部返回的 CompletableFuture 自身异常，f2 就以该异常完成
示例：
CompletableFuture<String> f1 = CompletableFuture.failedFuture(new RuntimeException("first"));
CompletableFuture<Integer> f2 = f1.thenCompose(s ->
CompletableFuture.completedFuture(s.length()) // 这行根本不会执行
);
// f2.isCompletedExceptionally() == true，异常同 f1
若想在 thenCompose 中“拦截并重试”，可用：
f1.handle((result, ex) -> {
if (ex != null) {
return retryAsync().thenApply(r -> r).join(); // 或更好：返回新的 CF，用 thenCompose 衔接
}
return CompletableFuture.completedFuture(result);
}).thenCompose(Function.identity()); // 展平一层
调试与监控异常丢失的关键点
CompletableFuture 静默失败常见原因：
- 忘记对最终 stage 调用 join() 或 get() —— 异常只在获取结果时才暴露
- 使用 whenComplete 或 thenAccept 但没配 exceptionally 或 handle，导致异常路径无处理
- 在自定义线程池中运行时，未设置 UncaughtExceptionHandler，ForkJoinPool 默认吞掉未处理异常
建议上线前加全局兜底：
ForkJoinPool.commonPool().setUncaughtExceptionHandler((t, e) ->
System.err.println("CF 未捕获异常：" + e)
);
或改用自定义线程池并配置 handler。
不复杂但容易忽略：异常传递不是“自动连通水管”，而是“需要你在每个接口处主动接驳”。handle 是最稳的接驳器。
