completablefuture 处理多任务依赖需区分串行、并行与混合结构:串行用 thencompose 扁平化嵌套;并行用 allof 或 thencombine 合并结果;异常用 exceptionally/handle 统一兜底;io 与 cpu 任务须配专用线程池。

CompletableFuture 处理多任务依赖,关键在于区分任务关系:是串行依赖、并行独立,还是混合结构。它不靠手动轮询或嵌套 get(),而是用声明式链路表达逻辑关系,让代码聚焦“做什么”,而不是“怎么等”。
串行依赖:用 thenCompose 扁平化传递结果
当后一步必须等前一步结果才能发起(比如查用户 → 查该用户的订单 → 查该订单的物流),必须用 thenCompose。它接收一个返回 CompletableFuture 的函数,自动拆包,避免出现 CompletableFuture<completablefuture>></completablefuture> 这种嵌套类型。
- 每步都得返回 CompletableFuture,不能直接 return 普通对象
- 如果某步可能为空(如用户不存在),提前用
filter或在 thenCompose 中判断并返回CompletableFuture.failedFuture() - 默认线程池是 ForkJoinPool.commonPool(),高并发或 IO 密集场景建议传入自定义线程池,例如
thenCompose(fn, ioExecutor)
并行独立:用 allOf 或 thenCombine 合并结果
多个任务互不依赖、可同时发起(比如查用户、查商品、查优惠券),就该并行执行再汇总。
-
allOf:等待全部完成,适合只关心“是否都做完”,不直接获取结果;配合
join()后再用各 future 的getNow()或join()取值 - thenCombine:两个任务都完成后,用函数合并结果(如相加、拼接);注意它是双输入单输出,和 thenCompose 的单输入单输出有本质区别
- 若任务数动态变化,可用
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))+ 流式 collect 收集结果
异常与兜底:用 exceptionally 和 handle 统一拦截
异步链中任意一环抛异常,整个链会中断。不能靠 try-catch 包裹链式调用,而要用专门的恢复方法。
- exceptionally:只在发生异常时触发,返回默认值,后续链继续执行
- handle:无论成功失败都会执行,适合做日志、清理或统一转换结果格式
- 慎用 whenComplete:它不改变结果值,仅做副作用(如记录耗时),异常仍会向上抛
线程调度:避免阻塞与资源争抢
默认线程池不是万能的。常见问题不是“能不能跑”,而是“跑在哪、会不会卡住别的任务”。
- IO 类操作(HTTP、DB)别挤在 commonPool 里,容易拖慢整个池;应配专用线程池,如
Executors.newCachedThreadPool()或固定大小的 IO 线程池 - CPU 密集型计算(如加解密、图像处理)建议用
Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()) - 需要强制异步切换线程(比如上游在 Netty IO 线程完成,下游不能继续占着它),优先选 thenComposeAsync 而非 thenCompose
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











