Java中合并CompletableFuture结果分两类：1. allOf+join()用于并行执行且无依赖的多个任务，需手动取结果；2. thenCombine等用于有依赖的任务组合，支持链式处理与异常捕获。
Java 中用 CompletableFuture 合并多个异步任务结果，核心是区分“并行执行+等待全部完成”和“按依赖顺序组合”两种场景。最常用的是 allOf 和 join() 配合，但要注意它返回 void，需手动提取结果；更推荐用 thenCombine、thenCollect（需自定义）或流式组合方式。
用 allOf + join() 汇总多个独立异步任务
适用于多个互不依赖、只需等全部结束再统一处理结果的场景（比如并发查多个服务，最后聚合）。
-
CompletableFuture.allOf(f1, f2, f3)返回一个CompletableFuture<Void>，只表示“全都完成了”，不带结果 - 必须单独调用每个 future 的
join()（或get()）来获取各自结果，否则拿不到数据 - 建议用数组或列表管理 futures，避免硬编码重复调用
示例：
CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> "A"); CompletableFuture<Integer> f2 = CompletableFuture.supplyAsync(() -> 123); CompletableFuture<Boolean> f3 = CompletableFuture.supplyAsync(() -> true); CompletableFuture<Void> all = CompletableFuture.allOf(f1, f2, f3); all.join(); // 等待全部完成 // 手动取结果（注意：join() 会阻塞当前线程，但此时已确保完成，不会真阻塞） String s = f1.join(); Integer i = f2.join(); Boolean b = f3.join();
用 thenCombine / thenAcceptBoth 组合两个有依赖的任务
当后一个任务需要前两个任务的结果作为输入时，用 thenCombine 最自然——它接收另一个 future 和一个 BiFunction。
立即学习“Java免费学习笔记（深入）”；
JavaStoryDevelop
下载
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
- 第一个 future 完成后，自动触发第二个 future，并把两者结果传给合并函数
- 返回新的
CompletableFuture<R>，类型由函数决定，支持链式调用 - 如果只是消费结果不产生新值，可用
thenAcceptBoth
示例：
CompletableFuture<String> name = CompletableFuture.supplyAsync(() -> "Alice");
CompletableFuture<Integer> age = CompletableFuture.supplyAsync(() -> 30);
CompletableFuture<String> info = name.thenCombine(age, (n, a) -> n + "(" + a + ")");
// 结果："Alice(30)"
合并多个不同类型的异步结果（3个及以上）
没有内置的 thenCombine3，但可通过嵌套或流式方式实现。推荐用嵌套 thenCombine，清晰且类型安全：
- 先 combine 前两个 → 得到中间结果 future
- 再将该 future 与第三个 combine → 得到最终结果
- 可封装为工具方法，如
combine3(f1,f2,f3, (a,b,c)->...)
简单嵌套示例：
CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> "X");
CompletableFuture<Integer> f2 = CompletableFuture.supplyAsync(() -> 100);
CompletableFuture<Double> f3 = CompletableFuture.supplyAsync(() -> 3.14);
CompletableFuture<String> result = f1
.thenCombine(f2, (s, i) -> s + "-" + i)
.thenCombine(f3, (s, d) -> s + "-" + d);
// 最终："X-100-3.14"
异常处理不能少：handle / exceptionally
多个异步任务中任一失败，默认会导致整个链中断。务必用 handle 或 exceptionally 捕获错误，避免静默失败：
-
exceptionally(Function<Throwable, T>)：只在异常时提供默认值，不处理正常结果 -
handle(BiFunction<T, Throwable, R>)：统一处理成功和异常，更灵活 - 对
allOf，要分别对每个 future 加异常处理，或在外层 try-catch
示例：
CompletableFuture<String> safe = CompletableFuture
.supplyAsync(() -> { throw new RuntimeException("boom"); })
.exceptionally(t -> "fallback");
// 结果是 "fallback"，不会抛出异常
