CompletableFuture 通过链式调用（thenApply/thenAccept/thenRun）、扁平化组合（thenCompose）、统一异常处理（exceptionally/handle）及并发协调（allOf/anyOf）替代回调地狱，实现线性、可读、健壮的异步编程。
用 CompletableFuture 替代回调地狱，核心是把嵌套的异步调用“拉平”，通过链式调用和组合操作让逻辑线性表达，而不是层层缩进。
用 thenApply / thenAccept / thenRun 串行处理结果
传统回调中，每个异步操作结束后都要写一个新回调，容易形成多层嵌套。而 CompletableFuture 提供了语义清晰的后续操作方法：
-
thenApply：接收上一步结果，返回新值（适合转换） -
thenAccept：接收结果但不返回（适合消费，如打印、存库） -
thenRun：不关心结果，只执行动作（如发通知）
例如：查用户 → 查订单 → 计算总金额，可写成：
userService.findById(123)
.thenCompose(user -> orderService.findByUserId(user.getId()))
.thenApply(orders -> orders.stream().map(Order::getAmount).reduce(0.0, Double::sum))
.thenAccept(total -> System.out.println("总消费：" + total));
用 thenCompose 处理返回 CompletableFuture 的操作
当某一步本身也返回 CompletableFuture（比如另一个异步调用），直接用 thenApply 会导致 CompletableFuture —— 这就是“扁平化”要解决的问题。thenCompose 就是专为此设计的，它自动展平一层。
对比：
-
thenApply：适合同步转换，或返回普通对象 -
thenCompose：适合返回新的CompletableFuture，避免嵌套
错误示范（回调地狱变体）：
future1.thenApply(x -> service.asyncCall(x)) // 返回 CompletableFuture，结果类型不对
正确写法：
future1.thenCompose(x -> service.asyncCall(x)) // 类型保持 CompletableFuture<t></t>
用 exceptionally / handle 统一处理异常
回调地狱里，每层都得单独 try-catch，非常重复。CompletableFuture 支持集中异常处理：
-
exceptionally(Function：捕获异常并提供默认值（类似) orElse） -
handle(BiFunction：无论成功失败都执行，可区分处理)
例如：
userService.findById(123)
.thenCompose(user -> orderService.findByUserId(user.getId()))
.exceptionally(t -> {
log.error("加载订单失败", t);
return Collections.emptyList();
})
.thenAccept(orders -> process(orders));
用 allOf / anyOf 并发协调多个任务
多个独立异步任务需要等全部完成（或任一完成），不再需要手写计数器或标志位。allOf 和 anyOf 返回新的 CompletableFuture，配合 join() 或后续链式操作使用：
-
CompletableFuture.allOf(f1, f2, f3).join()：阻塞等待全部完成（注意：不聚合结果） - 想拿到所有结果？用
stream.map(CompletableFuture::join).collect(...) -
anyOf返回最先完成的那个结果（类型为Object，需强转或统一包装）
实用小技巧：封装一个工具方法聚合多个 CompletableFuture 的结果：
public static <t> CompletableFuture<list>> allAsList(List<completablefuture>> futures) {
CompletableFuture<void> allDone = CompletableFuture.allOf(
futures.toArray(new CompletableFuture[0]));
return allDone.thenApply(v -> futures.stream()
.map(CompletableFuture::join)
.collect(Collectors.toList()));
}</void></completablefuture></list></t>
不复杂但容易忽略：别忘了线程上下文（如事务、MDC）、超时控制（orTimeout）、取消传播（completeOnTimeout）这些关键点，它们共同构成健壮的异步流程。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
