0

0

如何使用Java的ListenableFuture扩展异步功能_Guava并发工具应用

P粉602998670

P粉602998670

发布时间:2026-03-06 12:48:59

|

565人浏览过

|

来源于php中文网

原创

listenablefuture 更实用因其支持异步回调而非阻塞等待;需通过 listeningexecutorservice 创建,用 futures.addcallback 注册成功/失败处理,transform/catching 构建流水线,但 guava 28+ 起为 @beta,新项目宜优先选 completablefuture。

如何使用java的listenablefuture扩展异步功能_guava并发工具应用

为什么 ListenableFuture 比原生 Future 更实用

因为原生 Future 只能阻塞等待结果或轮询状态,没法真正“监听”完成事件;ListenableFuture 在完成时主动触发回调,适合链式异步处理、避免线程空转。

常见错误现象:用 future.get() 等待多个任务,导致线程卡死或响应延迟飙升;或者手动起线程轮询 isDone(),浪费资源又难维护。

  • 必须配合 ListeningExecutorService 创建(不能直接 new),否则监听器不生效
  • MoreExecutors.directExecutor() 适合轻量回调(如日志、简单状态更新),但别在里面做耗时操作,否则会阻塞调用线程
  • 监听器执行线程由传入的 Executor 决定,不是原始任务线程 —— 这点常被忽略,导致并发安全问题

怎么给异步任务加成功/失败回调

Futures.addCallback() 注册两个函数,分别处理成功和异常路径,比 try-catch + get() 更清晰、更不易漏错。

使用场景:HTTP 调用后刷新本地缓存、数据库写入失败时发告警、RPC 返回后组装 DTO。

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

小艺
小艺

华为公司推出的AI智能助手

下载
ListenableFuture<String> future = service.submitAsyncTask();
Futures.addCallback(future,
    new FutureCallback<String>() {
        public void onSuccess(String result) {
            cache.put("key", result);
        }
        public void onFailure(Throwable t) {
            logger.error("task failed", t);
        }
    },
    executor);
  • onSuccessonFailure 不会同时触发,且保证只调用一次
  • 如果回调里抛出异常,会被 executor 的未捕获异常处理器吞掉(默认静默),建议在回调内包一层 try-catch
  • 不要在 onSuccess 里再调 get() —— 此时结果已确定,直接用参数值即可

Futures.transform()Futures.catching() 怎么选

两者都返回新的 ListenableFuture,用于构建异步流水线:transform 处理正常结果转换,catching 专门兜底特定异常类型。

参数差异明显:transform 第二个参数是 AsyncFunction(返回新 ListenableFuture)或 Function(同步转换);catching 需显式指定异常类和 fallback 函数。

  • 想把 ListenableFuture<httpresponse></httpresponse> 转成 ListenableFuture<user></user>?用 transform + Function
  • 遇到 IOException 时返回默认值,其他异常继续上抛?用 catching,别用通用 onFailure
  • 性能影响:每次 transformcatching 都会包装一层 future,深层嵌套可能增加调度开销,但通常可忽略

Guava 28+ 中 ListenableFuture 的兼容性风险

Guava 28 开始标记 ListenableFuture 为 @Beta,且明确不承诺二进制兼容;Java 19+ 的虚拟线程(Project Loom)也未对其优化。生产环境升级 Guava 前必须验证。

容易踩的坑:用 CompletableFuture 替换时发现 transform 行为不一致(比如 null 处理)、或与旧版 Futures.allAsList() 返回类型冲突。

  • 新项目优先考虑 CompletableFuture(JDK 8+ 原生支持,API 更丰富,Loom 兼容性好)
  • 老系统还在用 Guava 回调链,就别强行切到 thenApply —— 混用两种 future 容易引发线程模型混乱
  • Futures.successfulAsList()Futures.inCompletionOrder() 这类聚合工具,在 CompletableFuture 中没有直接等价物,迁移成本高

真正麻烦的不是语法,是回调执行时机和线程归属——尤其当底层服务从线程池切换到虚拟线程时,directExecutor() 的行为会变得不可控。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
guava包作用
guava包作用

guava是一个java库,增强了java标准库,提供更有效率和易于使用的集合、实用程序、缓存和并发工具。想了解更多guava的相关内容,可以阅读本专题下面的文章。

271

2024.05.29

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

252

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

1029

2024.03.01

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

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

743

2023.08.10

function是什么
function是什么

function是函数的意思,是一段具有特定功能的可重复使用的代码块,是程序的基本组成单元之一,可以接受输入参数,执行特定的操作,并返回结果。本专题为大家提供function是什么的相关的文章、下载、课程内容,供大家免费下载体验。

497

2023.08.04

js函数function用法
js函数function用法

js函数function用法有:1、声明函数;2、调用函数;3、函数参数;4、函数返回值;5、匿名函数;6、函数作为参数;7、函数作用域;8、递归函数。本专题提供js函数function用法的相关文章内容,大家可以免费阅读。

166

2023.10.07

数据库三范式
数据库三范式

数据库三范式是一种设计规范,用于规范化关系型数据库中的数据结构,它通过消除冗余数据、提高数据库性能和数据一致性,提供了一种有效的数据库设计方法。本专题提供数据库三范式相关的文章、下载和课程。

383

2023.06.29

如何删除数据库
如何删除数据库

删除数据库是指在MySQL中完全移除一个数据库及其所包含的所有数据和结构,作用包括:1、释放存储空间;2、确保数据的安全性;3、提高数据库的整体性能,加速查询和操作的执行速度。尽管删除数据库具有一些好处,但在执行任何删除操作之前,务必谨慎操作,并备份重要的数据。删除数据库将永久性地删除所有相关数据和结构,无法回滚。

2108

2023.08.14

JavaScript浏览器渲染机制与前端性能优化实践
JavaScript浏览器渲染机制与前端性能优化实践

本专题围绕 JavaScript 在浏览器中的执行与渲染机制展开,系统讲解 DOM 构建、CSSOM 解析、重排与重绘原理,以及关键渲染路径优化方法。内容涵盖事件循环机制、异步任务调度、资源加载优化、代码拆分与懒加载等性能优化策略。通过真实前端项目案例,帮助开发者理解浏览器底层工作原理,并掌握提升网页加载速度与交互体验的实用技巧。

1

2026.03.06

热门下载

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

精品课程

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

共23课时 | 4.2万人学习

C# 教程
C# 教程

共94课时 | 10.8万人学习

Java 教程
Java 教程

共578课时 | 77.9万人学习

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

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