怎么利用 CompletableFuture 的 allOf 与 anyOf 实现复杂异步任务的响应式编排

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《怎么利用 CompletableFuture 的 allOf 与 anyOf 实现复杂异步任务的响应式编排》，这篇文章主要讲到等等知识，如果你对文章相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

CompletableFuture.allOf不能直接获取结果，因它只返回CompletableFuture且不收集值；需先allOf.join()等待完成，再对各Future调用join()取值。

allOf 为什么不能直接获取每个任务的结果

CompletableFuture.allOf 返回的是 CompletableFuture，它只负责等待所有子任务完成，不收集结果。想拿到每个 CompletableFuture 的返回值，必须手动调用各自的 join() 或 get()。常见错误是写成 allOf(f1, f2).join() 后直接以为能拿到一个结果数组——实际返回 null。

正确做法是先用 allOf 确保全部完成，再遍历原始 Future 列表取值：

CompletableFuture f1 = CompletableFuture.supplyAsync(() -> "a");
CompletableFuture f2 = CompletableFuture.supplyAsync(() -> 123);
CompletableFuture all = CompletableFuture.allOf(f1, f2);
all.join(); // 等待完成
String s = f1.join(); // 手动取值
Integer i = f2.join();

anyOf 返回的 CompletableFuture 是 Object 类型，类型擦除导致强转易出错

CompletableFuture.anyOf 返回 CompletableFuture