CompletableFuture 解决了传统 Future 无法链式处理、组合任务、非阻塞回调、异常统一处理等硬伤,支持 thenApply/thenCompose/anyOf/allOf 等编排能力,并提供 handle/whenComplete/exceptionally 等语义明确的回调机制。
CompletableFuture 解决了传统 Future 的哪些硬伤
Java 5 引入的
只能被动等待结果,无法链式处理、无法组合多个
异步任务
、也不能方便地处理异常或 fallback。它像一张单程票——你交出任务,只能等
阻塞拿结果,中间没任何干预能力。
而
(JDK 8 加入)补全了这整条异步流水线:支持非阻塞回调、任务编排、异常传播、超时控制、手动完成——本质是把“异步操作”真正变成可组合、可观察、可中断的编程单元。
一调就卡主线程;
的
、
等方法全部异步触发,不阻塞调用线程
多个 HTTP 请求要串行?传统写法嵌套回调(callback hell);
可自然平铺链式依赖
想等任意一个完成就继续?
直接返回新
;想等全部完成?用
可在任意时刻主动失败,比靠
抛异常更可控
什么时候该用 supplyAsync 而不是 new CompletableFuture().complete()
二者都能创建已完成的
,但语义和线程模型完全不同。
会把
提交到默认的
(或指定线程池),适合真正耗时的计算或 I/O;而
是立即完成,不涉及线程切换,适合模拟结果、测试或快速返回缓存值。
立即学习
“
Java免费学习笔记(深入)
”;
Eclipse导入Android或其他的JAVA项目的正确方法 WORD版
本文档主要讲述的是Eclipse导入Android或其他的JAVA项目的正确方法;希望本文档会给有需要的朋友带来帮助;感兴趣的朋友可以过来看看
下载
用
时注意:默认线程池不支持 IO 密集型任务长时间阻塞,容易拖垮整个
;IO 类操作建议传自定义线程池,比如
和
只能调用一次,重复调用无效;而
每次都新建一个异步任务
如果
是纯内存计算且极快(如 JSON 解析小对象),直接
更轻量,避免线程调度开销
handle、whenComplete、exceptionally 这三个回调的区别在哪
它们都用于响应完成事件,但职责边界清晰,混用容易导致逻辑错乱或异常丢失。
:无论成功或失败都会执行,必须返回值(可为 null),用于统一转换结果或兜底处理;
为 null 表示正常完成
:也是无论成败都执行,但不改变原始结果,返回仍是原
;适合打日志、清理资源,不能用来 fallback
:仅在异常时触发,且只接收
,返回替代值;它不会吞掉异常——如果 fallback 也抛异常,上游仍能捕获
常见错误:用
做 fallback(它不返回新值),或在
里抛出未检查异常却不处理(会导致下游
抛
)。
CompletableFuture.allOf() 返回 void,怎么拿到所有结果
只保证全部完成,并不聚合结果,返回类型是
——这是最容易踩的坑。它本身不持有各个子任务的返回值。
正确做法:先用
收集所有
,再调用
等待完成,最后用
或
逐个取值
示例:
如果真需要自动聚合,得自己封装:用
,或借助第三方库如
(Guava)
别指望
自动打包成 List —— 它的设计哲学就是“只管完成信号,不管数据”,这点和 RxJava 的
或
有本质区别。
Futureget()CompletableFutureFuture.get()CompletableFuturethenApplythenAcceptthenComposeCompletableFuture.anyOf()CompletableFutureallOf()completeExceptionally(new RuntimeException())get()CompletableFuturesupplyAsync(() -> doWork())doWork()ForkJoinPool.commonPool()new CompletableFuture().complete(value)supplyAsynccommonPoolsupplyAsync(() -> callHttp(), httpClientPool)complete()completeExceptionally()supplyAsyncdoWork()completedFuture(value)handle((result, ex) -> { ... })exwhenComplete((result, ex) -> { ... })CompletableFutureexceptionally(ex -> fallbackValue)ThrowablewhenCompletehandleget()CompletionExceptionallOf()CompletableFutureStreamCompletableFutureallOf()join()get()CompletableFuture f1 = CompletableFuture.supplyAsync(() -> "a");
CompletableFuture f2 = CompletableFuture.supplyAsync(() -> 42);
CompletableFuture all = CompletableFuture.allOf(f1, f2);
all.join(); // 等待全部完成
String s = f1.join(); // 再单独取
Integer i = f2.join(); stream.map(CompletableFuture::join).collect(...)CompletableFutures.allAsList()allOf()zipcombineLatest