Java线程池结合CompletableFuture实现多任务异步汇聚，关键在于显式指定自定义线程池（避免commonPool）、用supplyAsync+allOf+join组合执行与结果收集、按需选用thenCombine/thenCompose处理依赖关系，并添加超时和异常兜底保障可靠性。
Java 线程池结合 CompletableFuture 实现多任务异步汇聚，关键在于让 CompletableFuture 显式运行在你可控的线程池上，再用组合 API 并行执行、等待完成、提取并合并结果，全程避免掉入 ForkJoinPool.commonPool 的坑。
必须显式传入自定义线程池
CompletableFuture 默认使用 ForkJoinPool.commonPool()，它共享全局资源，容易被其他模块抢占，导致任务延迟或阻塞。生产环境务必传入专属线程池：
- 用 supplyAsync(Supplier, Executor) 替代无参版本，确保有返回值的任务走指定线程池
- 避免 runAsync（无返回值），除非真不需要结果；汇聚场景基本都靠 supplyAsync 构建可 join 的 future
- 线程池建议用 ThreadPoolExecutor 配置：核心线程数根据 IO/CPU 类型设定，队列推荐 LinkedBlockingQueue，拒绝策略选 CallerRunsPolicy 防雪崩
用 allOf + join 完成并行执行与结果收集
allOf 不返回数据，只表示“全部完成”，所以不能直接靠它拿结果。正确做法是：
- 先用 supplyAsync 提交多个任务，存进 List
> - 调用 CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])) 获取一个“完成信号”
- 对原始 futures 列表遍历调用 join()（非 get()，不抛检异常），安全提取每个结果
- 最后用 stream.collect 或手动组装，得到汇总后的 List、Map 或聚合对象
依赖型或两两合并用 thenCompose / thenCombine
当任务不是完全独立，而是存在先后或配对关系时，allOf 就不够用了：
立即学习“Java免费学习笔记（深入）”；
- thenCombine：适合两个并行任务完成后合并结果，比如“查用户信息”和“查订单列表” → 组装用户订单视图
- thenCompose：适合前序结果驱动后续异步调用，比如“根据 token 获取 userId” → “用 userId 查详情”，自动展平嵌套 future
- 这两个方法都有带 Executor 的重载，记得传入你的线程池，否则可能意外切回 commonPool
加上超时和异常兜底才真正可靠
真实业务中，单个任务失败或卡死不能拖垮整个汇聚流程：
- 每个 supplyAsync 后接 orTimeout(3, SECONDS) 设置单任务超时
- 紧跟 exceptionally(ex -> fallbackValue) 提供降级值，保证后续汇聚不因某一项失败而中断
- allOf 之后若需整体超时控制，可用 CompletableFuture.anyOf(timeoutFuture, allOfFuture).join() 做兜底熔断
