0

0

Java异步任务怎么获取结果 Java CompletableFuture用法【进阶】

月夜之吻

月夜之吻

发布时间:2026-03-12 09:55:31

|

301人浏览过

|

来源于php中文网

原创

completablefuture.get()会阻塞线程,切勿在主线程直接调用;应使用thenapply/thenaccept/whencomplete等非阻塞方式处理结果,必要时加超时;组合操作需分清thencompose(扁平化链式异步)与thencombine(合并两个独立结果);异常需用exceptionally或handle显式处理;io任务必须指定自定义线程池,避免耗尽forkjoinpool.commonpool()。

java异步任务怎么获取结果 java completablefuture用法【进阶】

CompletableFuture.get() 会阻塞线程,别在主线程里直接调用

很多人一上来就写 future.get(),结果发现 UI 卡死、HTTP 请求超时、线程池耗尽。这是因为 get() 是同步阻塞的,会一直等到结果返回或抛异常,期间当前线程无法做其他事。

正确做法是用非阻塞方式消费结果:

  • thenApply() / thenAccept() 做后续计算或副作用(如更新 UI、写日志)
  • whenComplete() 统一处理成功/失败(适合兜底日志或资源清理)
  • 真要等结果,至少加超时: future.get(3, TimeUnit.SECONDS),并捕获 TimeoutException

多个异步任务怎么串行/并行执行?看这几个组合方法

thenCompose()thenCombine() 容易混淆,关键区别在于「是否返回新的 CompletableFuture」:

ColorMagic
ColorMagic

AI调色板生成工具

下载
  • thenCompose():上一个任务返回的是 CompletableFuture<t></t>,你接着返回另一个 CompletableFuture<r></r>(比如查完用户再查订单),它会自动扁平化,避免嵌套 CompletableFuture<completablefuture>></completablefuture>
  • thenCombine():两个独立的 CompletableFuture 都已完成,你把它们的结果一起拿来算(比如合并用户信息和缓存配置)
  • allOf() 只返回 CompletableFuture<void></void>,不带结果;想拿到所有结果得手动 join() 每个子 future,或者用 allOf(...).thenApply(v -> Stream.of(f1, f2, f3).map(CompletableFuture::join).collect(...))

异常处理不能只靠 catch,CompletableFuture 的 fail-fast 机制很关键

CompletableFuture 一旦某个阶段抛出未捕获异常,后续的 thenApply() 等函数不会执行,而是跳到最近的 exceptionally()handle()。这点和普通 try-catch 不同,容易误以为“没写 catch 就不会报错”。

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

  • exceptionally(Function<throwable t>)</throwable>:只在异常时触发,返回默认值,但无法区分异常类型
  • handle(BiFunction<t throwable r>)</t>:无论成功失败都进这里,适合统一记录状态 + 返回 fallback 值
  • 别在 thenApply() 里 throw 新异常却不处理——这会让整个链路中断,下游收不到任何信号

线程池选错会导致性能崩盘,supplyAsync 默认用 ForkJoinPool.commonPool()

supplyAsync(() -> heavyWork()) 看似简单,但默认用的是 ForkJoinPool.commonPool(),这个池子大小等于 CPU 核心数,专为短小、CPU 密集型任务设计。一旦你丢进去耗时 IO 操作(比如 HTTP 调用、数据库查询),线程很快被占满,新任务排队,吞吐骤降。

  • IO 类任务务必指定自定义线程池:supplyAsync(() -> api.call(), ioExecutor)
  • 推荐用 ThreadPoolExecutor,核心线程数设为预期并发量,拒绝策略建议 CallerRunsPolicy(让调用方自己执行,起到自然限流作用)
  • 别用 Executors.newCachedThreadPool(),它无限创建线程,容易 OOM
实际写业务逻辑时,最常被忽略的是「异常传播路径」和「线程池隔离」——前者让错误静默丢失,后者让一个慢接口拖垮整个服务。这两个点不抠清楚,CompletableFuture 写得再链式也白搭。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
javascriptvoid(o)怎么解决
javascriptvoid(o)怎么解决

javascriptvoid(o)的解决办法:1、检查语法错误;2、确保正确的执行环境;3、检查其他代码的冲突;4、使用事件委托;5、使用其他绑定方式;6、检查外部资源等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

186

2023.11.23

java中void的含义
java中void的含义

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

134

2025.11.27

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

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

1923

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 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

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

精品课程

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

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