0

0

Java中如何使用CompletableFuture实现异步处理

P粉602998670

P粉602998670

发布时间:2025-10-24 09:54:02

|

264人浏览过

|

来源于php中文网

原创

completablefuture 提供非阻塞异步编程支持,可通过 supplyasync/runasync 创建任务,使用 thenapply/thenaccept/thenrun 处理结果,以 thencompose/thencombine 组合任务,用 allof/anyof 控制多任务,通过 exceptionally/handle/whencomplete 处理异常,结合自定义线程池优化资源管理,提升程序响应性与吞吐量。

java中如何使用completablefuture实现异步处理

在Java中,CompletableFuture 是实现异步编程的重要工具,它提供了对 Future 的增强支持,允许以非阻塞方式执行任务,并通过回调机制处理结果或异常。相比传统的 Future,CompletableFuture 支持链式调用、组合多个异步任务以及更灵活的错误处理。

创建异步任务

你可以使用 CompletableFuture.supplyAsync()runAsync() 来启动一个异步任务:

  • supplyAsync:用于有返回值的任务,接收一个 Supplier 函数式接口。
  • runAsync:用于无返回值的任务,接收一个 Runnable 接口。

示例:

赣极购物商城网店建站软件系统
赣极购物商城网店建站软件系统

大小仅1兆左右 ,足够轻便的商城系统; 易部署,上传空间即可用,安全,稳定; 容易操作,登陆后台就可设置装饰网站; 并且使用异步技术处理网站数据,表现更具美感。 前台呈现页面,兼容主流浏览器,DIV+CSS页面设计; 如果您有一定的网页设计基础,还可以进行简易的样式修改,二次开发, 发布新样式,调整网站结构,只需修改css目录中的css.css文件即可。 商城网站完全独立,网站源码随时可供您下载

下载
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return "Hello from async";
});

你也可以传入自定义线程池来控制资源:

立即学习Java免费学习笔记(深入)”;

ExecutorService executor = Executors.newFixedThreadPool(4);
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
return "Task executed in custom pool";
}, executor);

处理结果和回调

使用 thenApplythenAcceptthenRun 等方法可以在任务完成后执行后续操作:

  • thenApply:接收上一步的结果并返回新的结果。
  • thenAccept:消费结果但不返回值。
  • thenRun:不关心结果,只运行一段逻辑。

示例:

future.thenApply(result -> result + " processed")
.thenAccept(System.out::println)
.thenRun(() -> System.out.println("Done"));

组合多个异步任务

CompletableFuture 提供了多种方式组合多个异步操作:

  • thenCompose:用于串行组合两个依赖的任务(类似 flatMap)。
  • thenCombine:并行执行两个任务,并合并结果。
  • allOfanyOf:等待多个任务完成。

串行任务示例:

CompletableFuture step1 = CompletableFuture.supplyAsync(() -> "Result1");
CompletableFuture step2 = step1.thenCompose(result ->
CompletableFuture.supplyAsync(() -> result + " -> Result2")
);

并行合并结果:

CompletableFuture task1 = CompletableFuture.supplyAsync(() -> "A");
CompletableFuture task2 = CompletableFuture.supplyAsync(() -> "B");
task1.thenCombine(task2, (a, b) -> a + b).thenAccept(System.out::println); // 输出 AB

等待所有任务完成:

CompletableFuture all = CompletableFuture.allOf(task1, task2);
all.thenRun(() -> System.out.println("All tasks finished"));

异常处理

异步任务中可能发生异常,CompletableFuture 提供了专门的异常处理方法:

  • exceptionally:捕获异常并提供默认值。
  • handle:无论是否发生异常都会执行,可用于统一处理结果和异常。
  • whenComplete:类似 handle,但不能修改结果,仅用于监听。

示例:

CompletableFuture.supplyAsync(() -> {
throw new RuntimeException("Oops!");
}).exceptionally(ex -> {
System.err.println("Error: " + ex.getMessage());
return "Fallback Value";
}).thenAccept(System.out::println);

基本上就这些。CompletableFuture 让 Java 的异步编程变得直观且强大,合理使用可以显著提升程序响应性和吞吐量,尤其是在 I/O 密集型或远程调用场景中。注意避免阻塞主线程(如不必要的 get() 调用),并记得关闭自定义线程池。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
scripterror怎么解决
scripterror怎么解决

scripterror的解决办法有检查语法、文件路径、检查网络连接、浏览器兼容性、使用try-catch语句、使用开发者工具进行调试、更新浏览器和JavaScript库或寻求专业帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

492

2023.10.18

500error怎么解决
500error怎么解决

500error的解决办法有检查服务器日志、检查代码、检查服务器配置、更新软件版本、重新启动服务、调试代码和寻求帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

382

2023.10.25

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1925

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

656

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2392

2025.12.29

java接口相关教程
java接口相关教程

本专题整合了java接口相关内容,阅读专题下面的文章了解更多详细内容。

47

2026.01.19

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

765

2023.08.10

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

765

2023.08.10

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

76

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4.3万人学习

C# 教程
C# 教程

共94课时 | 11.2万人学习

Java 教程
Java 教程

共578课时 | 80.9万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号