CompletableFuture的thenCompose与thenCombine_逻辑串行与并行的选择

thencompose适用于串行依赖的异步调用，将前序结果作为参数触发下一个completablefuture；thencombine适用于两个独立异步任务完成后的结果聚合，要求任务提前启动以实现真正并发。

thenCompose 适合串行依赖：后一个异步操作要等前一个的结果才能发起

当你需要把 CompletableFuture<a></a> 的结果作为参数，去触发另一个返回 CompletableFuture<b></b> 的异步调用时，thenCompose 是唯一干净的选择。它会“扁平化”嵌套的 CompletableFuture<completablefuture>></completablefuture>，避免多层 join() 或手动解包。

常见错误现象：thenApply 返回了 CompletableFuture<b></b>，结果整个链变成 CompletableFuture<completablefuture>></completablefuture>，后续调用 get() 会卡住或抛出 ClassCastException。

• 必须传入一个函数，形如 a -> CompletableFuture<b></b>；不能直接传同步方法或返回 B 的函数
• 如果上游异常，thenCompose 的函数根本不会执行；想兜底要用 exceptionally 或 handle
• 典型场景：查用户 ID → 根据 ID 查订单 → 根据订单查物流，每步都是异步 HTTP 调用

userFuture.thenCompose(userId -> orderService.findByUserId(userId))
          .thenCompose(orders -> logisticsService.traceByOrders(orders));

thenCombine 适合并行汇合：两个独立异步任务都完成后，用它们的结果做聚合

thenCombine 不改变执行顺序，只负责“等两个 CompletableFuture 都完成”，然后把它们的结果一起交给你的合并函数。它不关心谁快谁慢，也不要求有依赖关系。

常见错误现象：误以为 thenCombine 会自动让两个任务并发执行——其实它们必须**提前启动**，否则会阻塞等待第一个完成才开始第二个（变成伪并行）。

Calliper 文档对比神器

文档内容对比神器

下载

• 两个 CompletableFuture 必须是已提交、正在运行（或已完成）的状态，不能是“懒加载”的新构造体
• 合并函数签名是 (a, b) -> R，接收两个原始结果，不是 CompletableFuture
• 任一上游失败，整个链就失败；需统一兜底请在外层加 exceptionally

CompletableFuture<String> user = userService.findById(123);
CompletableFuture<String> profile = profileService.load(123);
user.thenCombine(profile, (u, p) -> u + " | " + p); // 两者真正并发

别在 thenCompose 里写阻塞调用，也别在 thenCombine 前漏掉 .fork()

这两个方法默认使用公共 ForkJoinPool.commonPool()，一旦你在 thenCompose 的 lambda 里调用 Thread.sleep()、JDBC 同步查询或 Files.readAllBytes()，就会拖垮整个池子，影响其他异步任务。

同样，如果第二个任务是在 thenCombine 里才 new 出来的（比如 f1.thenCombine(new CompletableFuture(), ...)），那它根本不会跑——因为没被提交到线程池。

• 阻塞操作必须包裹进 CompletableFuture.supplyAsync(..., blockingExecutor)
• 所有异步任务务必在 thenCombine 之前就调用 supplyAsync / submit 等真正触发执行
• 检查是否真并发：打日志看两个任务的开始时间戳，别只信代码位置

异常传播路径不同：thenCompose 可中断链，thenCombine 是双路依赖

thenCompose 的函数本身抛异常，会终结当前链；而 thenCombine 要求两个上游都成功，任一失败都会跳过合并函数，直接走异常分支。

容易忽略的一点：如果第一个 CompletableFuture 失败，第二个还在跑，thenCombine 不会主动取消它——资源泄漏风险真实存在。

• thenCompose 异常后，下游的 thenAccept 不会执行；但 whenComplete 仍会进
• thenCombine 没有内置取消联动，需要自己用 cancel(true) 配合 whenComplete 手动清理
• 生产环境建议统一用 handle 替代 thenCompose + exceptionally，减少分支遗漏