java中组合completablefuture异步任务的核心是thencombine（合并两个结果）、allof（等待全部完成）、anyof（获取最先结果），需注意线程池配置与异常处理。
Java 中用 CompletableFuture 组合多个异步任务结果，核心是利用其链式方法（如 thenCombine、thenAcceptBoth、allOf、anyOf）把独立的异步操作串起来或并行聚合，避免手动阻塞等待。
用 thenCombine 合并两个异步结果
当需要等两个异步任务都完成，并把它们的结果一起处理时，thenCombine 最常用。它接收另一个 CompletableFuture 和一个二元函数，返回新的 CompletableFuture。
- 第一个任务执行完后不会阻塞，而是注册回调；第二个任务也异步运行，两者真正并行
- 只有两个都完成，才会触发组合逻辑；任一异常都会传递到返回的 future 中
- 示例：查用户信息 + 查订单数，合并成用户概览
// 伪代码示意
CompletableFuture<user> userFut = CompletableFuture.supplyAsync(() -> dao.findUser(id));<br> CompletableFuture<integer> orderCountFut = CompletableFuture.supplyAsync(() -> dao.countOrders(id));<br><br> CompletableFuture<usersummary> summaryFut = userFut.thenCombine(orderCountFut,<br> (user, count) -> new UserSummary(user.getName(), count));</usersummary></integer></user>
用 allOf 等待全部完成并收集结果
CompletableFuture.allOf 适合批量启动多个异步任务，且只关心“是否全部结束”，不直接返回结果集合——需手动从各个 future 中 join() 取值。
- 返回的是
CompletableFuture<void></void>，所以必须额外保存原始 future 引用 - 若任一任务异常，
allOf返回的 future 仍会完成，但调用join()时会抛出CompletionException - 建议配合
handle或exceptionally做统一错误处理
// 示例：批量发送通知
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
List<completablefuture>> sends = emails.stream()<br>
.map(email -> CompletableFuture.supplyAsync(() -> mailService.send(email)))<br>
.collect(Collectors.toList());<br><br>
CompletableFuture<void> allDone = CompletableFuture.allOf(sends.toArray(new CompletableFuture[0]));<br>
allDone.thenRun(() -> {<br>
List<boolean> results = sends.stream().map(CompletableFuture::join).collect(Collectors.toList());<br>
System.out.println("全部发送完成，成功数：" + results.stream().filter(b -> b).count());<br>
});</boolean></void></completablefuture>
用 anyOf 获取最先完成的结果
CompletableFuture.anyOf 返回一个 CompletableFuture<object></object>，在任意一个入参 future 完成时就完成，结果是那个 future 的值（类型为 Object，需手动强转）。
- 适合“多源查询取最快响应”的场景，比如同时查缓存、DB、远程服务
- 注意：结果类型擦除，推荐用
handle做类型安全处理，或改用更明确的封装方式 - 失败的任务不影响
anyOf完成，除非全部失败（此时完成值为null，异常需通过exceptionally捕获）
// 示例：三路查询选最快
CompletableFuture<string> cacheFut = CompletableFuture.supplyAsync(() -> cache.get(key));<br>
CompletableFuture<string> dbFut = CompletableFuture.supplyAsync(() -> db.load(key));<br>
CompletableFuture<string> apiFut = CompletableFuture.supplyAsync(() -> http.get("/data/" + key));<br><br>
CompletableFuture<object> fastest = CompletableFuture.anyOf(cacheFut, dbFut, apiFut);<br>
fastest.handle((result, ex) -> {<br>
if (ex != null) return "fallback";<br>
return (String) result; // 注意类型转换<br>
});</object></string></string></string>
组合时的异常与线程控制要点
默认情况下，thenApply、thenCombine 等方法在前一个 future 完成的**同一线程**中执行（即由完成它的线程调用回调），容易造成线程阻塞或上下文污染。生产中应显式指定执行器。
- 所有带
Async后缀的方法（如thenApplyAsync、thenCombineAsync）可传入自定义Executor - 不要用
ForkJoinPool.commonPool()处理 IO 密集型任务，应创建专用线程池（如Executors.newCachedThreadPool()或固定大小的ThreadPoolExecutor） - 异常传播：未处理的异常会保留在 future 中，调用
join()或get()时才暴露；可用exceptionally、handle、whenComplete拦截
// 推荐写法：指定线程池 + 异常兜底
ExecutorService ioPool = Executors.newCachedThreadPool();<br>
userFut.thenCombineAsync(orderCountFut, (u, c) -> new UserSummary(u, c), ioPool)<br>
.exceptionally(ex -> new UserSummary("未知用户", 0));Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
