Java中的CompletableFuture核心用法和常见场景
更新时间：2025年12月10日 11:37:54 作者：猩火燎猿
CompletableFuture是Java8引入的强大的异步编程工具,支持链式异步编程、组合、异常处理和回调,介绍其核心用法,通过实用示例和注意事项,展示了如何在实际场景中应用CompletableFuture,以提高并发能力和响应速度,感兴趣的朋友跟随小编一起看看吧
1、引言
CompletableFuture 是 Java 8 引入的一个非常强大的异步编程工具，属于 java.util.concurrent 包。它不仅支持异步执行任务，还支持任务的组合、异常处理、回调等丰富的操作。下面我会详细介绍 CompletableFuture 的核心用法和常见场景。
2. 基本概念
- Future：早期的异步结果表示，功能有限，只能通过
get()阻塞获取结果。 - CompletableFuture：增强版的 Future，支持链式异步编程、组合、异常处理、回调等。
3. 创建 CompletableFuture
3.1. 手动创建
CompletableFuture<String> future = new CompletableFuture<>();
// 可以手动完成
future.complete("Hello");3.2. 通过静态工厂方法
supplyAsync：有返回值，异步执行runAsync：无返回值，异步执行
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
return "Hello CompletableFuture";
});
CompletableFuture<Void> future2 = CompletableFuture.runAsync(() -> {
// 执行某些操作
});4. 获取结果
get()：阻塞等待结果join()：类似于get()，但遇到异常会抛出 unchecked 异常
String result = future1.get(); // 可能抛出异常 String result2 = future1.join(); // RuntimeException
5. 回调和链式操作
5.1. thenApply / thenApplyAsync
对结果进行转换（有返回值）
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> 100)
.thenApply(i -> i + 10); // 结果为1105.2. thenAccept / thenAcceptAsync
对结果做处理，无返回值
CompletableFuture.supplyAsync(() -> "hello")
.thenAccept(s -> System.out.println(s));5.3. thenRun / thenRunAsync
无参数、无返回值，仅执行后续操作
CompletableFuture.supplyAsync(() -> "hello")
.thenRun(() -> System.out.println("任务执行完毕"));6. 任务组合
5.1. thenCombine / thenCombineAsync
两个任务都完成后，合并结果
CompletableFuture<Integer> f1 = CompletableFuture.supplyAsync(() -> 10); CompletableFuture<Integer> f2 = CompletableFuture.supplyAsync(() -> 20); CompletableFuture<Integer> result = f1.thenCombine(f2, (a, b) -> a + b); // 30
6.2. thenCompose / thenComposeAsync
任务依赖，前一个结果作为后一个输入
CompletableFuture<String> f = CompletableFuture.supplyAsync(() -> "Hello")
.thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " World"));6.3. allOf / anyOf
等待多个任务全部/任一完成
CompletableFuture<Void> all = CompletableFuture.allOf(f1, f2); all.join(); // 等待全部完成 CompletableFuture<Object> any = CompletableFuture.anyOf(f1, f2); Object fastest = any.join(); // 任意一个完成即可
7. 异常处理
7.1. exceptionally
捕获异常，返回默认值
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("出错了");
}).exceptionally(e -> {
System.out.println(e.getMessage());
return 0;
});7.2. handle / handleAsync
无论成功或失败都处理
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("出错了");
}).handle((result, ex) -> {
if (ex != null) {
System.out.println(ex.getMessage());
return 0;
}
return result;
});8. 自定义线程池
默认使用 ForkJoinPool.commonPool()，可以自定义线程池：
ExecutorService executor = Executors.newFixedThreadPool(2); CompletableFuture.supplyAsync(() -> "hello", executor);
9. 实用示例
9.1. 多个异步任务并发执行，最后汇总
CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> "A");
CompletableFuture<String> f2 = CompletableFuture.supplyAsync(() -> "B");
CompletableFuture<String> f3 = CompletableFuture.supplyAsync(() -> "C");
CompletableFuture<Void> all = CompletableFuture.allOf(f1, f2, f3);
all.thenRun(() -> {
try {
System.out.println(f1.get() + f2.get() + f3.get());
} catch (Exception e) {
e.printStackTrace();
}
});10. 注意事项
- 尽量避免阻塞（如
get()），推荐使用回调。 - 注意线程池资源，合理分配，避免 OOM。
- 处理好异常，避免线程池线程被异常吞掉。
11. 进阶用法
11.1. 串联和并联任务
串联（依赖关系）
当一个任务的结果依赖于另一个任务时，使用 thenCompose：
CompletableFuture<String> getUserId = CompletableFuture.supplyAsync(() -> "user123");
CompletableFuture<String> getUserInfo = getUserId.thenCompose(id ->
CompletableFuture.supplyAsync(() -> "用户信息：" + id)
);并联（聚合结果）
多个任务并发执行，最后聚合结果：
CompletableFuture<Integer> t1 = CompletableFuture.supplyAsync(() -> 1);
CompletableFuture<Integer> t2 = CompletableFuture.supplyAsync(() -> 2);
CompletableFuture<Integer> t3 = CompletableFuture.supplyAsync(() -> 3);
CompletableFuture<List<Integer>> all = CompletableFuture.allOf(t1, t2, t3)
.thenApply(v -> {
List<Integer> result = new ArrayList<>();
result.add(t1.join());
result.add(t2.join());
result.add(t3.join());
return result;
});11.2. 超时控制
Java 9 后，CompletableFuture 增加了超时相关方法：
future.orTimeout(3, TimeUnit.SECONDS)
.exceptionally(ex -> {
System.out.println("超时啦");
return null;
});或自己实现：
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
Thread.sleep(5000);
return "hello";
});
try {
String result = future.get(2, TimeUnit.SECONDS); // 2秒超时
} catch (TimeoutException e) {
System.out.println("超时了");
}11.3. 异步流水线
你可以链式地组合多个异步操作，形成“流水线”：
CompletableFuture.supplyAsync(() -> "A")
.thenApply(s -> s + "B")
.thenApply(s -> s + "C")
.thenAccept(System.out::println); // 输出 ABC11.4. 处理异常和兜底方案
推荐使用 handle 或 exceptionally 做兜底：
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("出错了");
})
.handle((result, ex) -> ex == null ? result : -1);11.5. 自定义线程池的好处
- 控制线程数量，避免公共线程池被占满。
- 适合高并发、IO密集型场景。
ExecutorService executor = Executors.newFixedThreadPool(10); CompletableFuture.supplyAsync(() -> "业务逻辑", executor);
12. 实战场景举例
12.1. 微服务并发调用
假设要并发调用三个微服务接口，最后聚合结果：
CompletableFuture<String> api1 = CompletableFuture.supplyAsync(() -> callApi1());
CompletableFuture<String> api2 = CompletableFuture.supplyAsync(() -> callApi2());
CompletableFuture<String> api3 = CompletableFuture.supplyAsync(() -> callApi3());
CompletableFuture<Void> all = CompletableFuture.allOf(api1, api2, api3);
all.thenAccept(v -> {
String r1 = api1.join();
String r2 = api2.join();
String r3 = api3.join();
System.out.println("聚合结果：" + r1 + r2 + r3);
});12.2. 异步写数据库+异步发消息
CompletableFuture<Void> saveDb = CompletableFuture.runAsync(() -> saveToDb());
CompletableFuture<Void> sendMsg = CompletableFuture.runAsync(() -> sendMsg());
CompletableFuture.allOf(saveDb, sendMsg)
.thenRun(() -> System.out.println("所有操作完成"));13. 常见问题与建议
- 线程池泄漏：线程池要合理关闭，避免资源泄漏。
- 异常未处理：建议所有链路最后加
.exceptionally或.handle。 - 阻塞等待：尽量用回调而不是
get()或join()。 - 链式操作：推荐链式编程，代码更清晰。
总结
CompletableFuture 是 Java 异步编程的利器，支持丰富的组合、回调和异常处理能力。合理使用可以极大提升程序的并发能力和响应速度。
到此这篇关于Java中的CompletableFuture核心用法和常见场景的文章就介绍到这了,更多相关java completablefuture使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍了Spring中的使用@Async异步调用方法，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
Spring线程池ThreadPoolExecutor配置并且得到任务执行的结果
今天小编就为大家分享一篇关于Spring线程池ThreadPoolExecutor配置并且得到任务执行的结果，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧2019-03-03
循环依赖是指在Spring Boot 应用程序中，两个或多个类之间存在彼此依赖的情况，形成一个循环依赖链。这篇文章主要介绍了SpringBoot循环依赖的症状和解决方法2023-04-04
Spring MVC是个灵活的框架,返回JSON数据的也有很多五花八门的方式,下面这篇文章主要给大家介绍了关于Spring MVC中JSON数据处理方式的相关资料,需要的朋友可以参考下2024-01-01
详谈hibernate,jpa与spring data jpa三者之间的关系
这篇文章主要介绍了hibernate,jpa与spring data jpa三者之间的关系，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
这篇文章主要介绍了Java线程之程安全与不安全代码示例，还是比较不错的，这里分享给大家，供需要的朋友参考。2017-11-11
这篇文章主要介绍了Java中实现接口与继承的区别及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-03-03
这篇文章主要为大家详细介绍了java实现扑克牌发牌器，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-04-04
Java java.lang.InstantiationException异常案例详解
这篇文章主要介绍了Java java.lang.InstantiationException异常案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-08-08
解决IDEA 2020.1版本 maven Test命令出现导包错误的问题
这篇文章主要介绍了IDEA 2020.1版本 maven Test命令出现导包错误的问题及解决方法，本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-08-08
最新评论