Java 异步编程中怎么组合多个 CompletableFuture 返回结果-java教程-PHP中文网

java组合completablefuture的核心是按需选择组合逻辑：并行用allof+join或thenapply聚合列表，两两合并用thencombine/thenacceptboth，串行依赖用thencompose，且需用exceptionally或handle处理异常。

java 异步编程中怎么组合多个 completablefuture 返回结果

Java 中组合多个 CompletableFuture 的结果，核心是用好它的静态工厂方法和链式组合方法。关键不在于“等所有任务完成”，而在于明确你想要的组合逻辑：是并行执行后聚合、按顺序串行、还是有依赖关系？下面分几种常见场景说明。

并行执行 + 汇总结果（allOf + join）

适用于多个独立异步任务，全部完成后统一处理结果。注意：CompletableFuture.allOf() 返回的是 CompletableFuture<void></void>，它不携带结果，需手动从各个 future 中取值。

先启动所有任务，收集到一个 CompletableFuture[] 或 List<completablefuture>></completablefuture>
用 CompletableFuture.allOf(futures...) 等待全部完成
再通过 join() 或 get() 分别获取每个 future 的结果

示例：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

CompletableFuture<string> f1 = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture<integer> f2 = CompletableFuture.supplyAsync(() -> 42);
CompletableFuture<boolean> f3 = CompletableFuture.supplyAsync(() -> true);

// 等待全部完成
CompletableFuture.allOf(f1, f2, f3).join();

// 手动提取结果（注意类型安全）
String s = f1.join();
Integer i = f2.join();
Boolean b = f3.join();
</boolean></integer></string>

并行执行 + 自动聚合为列表（thenCombine / thenAcceptBoth 不适用，改用自定义组合）

allOf 本身不返回结果，若想一步得到装满结果的集合，可借助 thenApply 配合流操作：

把多个 future 放进 list
用 allOf 等待完成，再用 thenApply 转换为结果集合

示例：

List<completablefuture>> futures = Arrays.asList(
    CompletableFuture.supplyAsync(() -> "a"),
    CompletableFuture.supplyAsync(() -> "b"),
    CompletableFuture.supplyAsync(() -> "c")
);

CompletableFuture<list>> allResult = CompletableFuture.allOf(
    futures.toArray(new CompletableFuture[0]))
    .thenApply(v -> futures.stream()
        .map(CompletableFuture::join)
        .collect(Collectors.toList()));
</list></completablefuture>

两两组合结果（thenCombine / thenAcceptBoth）

适合两个 future 有明确依赖关系，且希望把它们的结果合并成新值：

thenCombine(other, BiFunction)：返回带新结果的 future（推荐）
thenAcceptBoth(other, BiConsumer)：只消费两个结果，不产生新 future

示例：

CompletableFuture<string> name = CompletableFuture.supplyAsync(() -> "Alice");
CompletableFuture<integer> age  = CompletableFuture.supplyAsync(() -> 30);

CompletableFuture<string> desc = name.thenCombine(age, (n, a) -> n + " is " + a + " years old");
</string></integer></string>

串行依赖（thenCompose）

当前 future 完成后，返回**另一个 future**（即“异步中嵌套异步”），要用 thenCompose，不是 thenApply：

thenApply：返回普通值 → 包装成已完成的 future
thenCompose：返回 future → 扁平化链接，避免 future 套 future

示例（查用户 → 查其订单 → 汇总）：

CompletableFuture<user> userFut = fetchUser(123);
CompletableFuture<list>> ordersFut = 
    userFut.thenCompose(user -> fetchOrders(user.getId()));
</list></user>

不复杂但容易忽略：组合时务必注意异常传播——未显式 handle 的异常会让整个链失败；建议在关键节点加 exceptionally() 或 handle() 做兜底。