原文地址 译者:罗立树 校对:方腾飞
并发编程是一个难题,但是一个强大而简单的抽象可以显著的简化并发的编写。出于这样的考虑,Guava 定义了 ListenableFuture接口并继承了JDK concurrent包下的Future 接口。
我们强烈地建议你在代码中多使用ListenableFuture来代替JDK的 Future, 因为:
- 大多数Futures 方法中需要它。
- 转到ListenableFuture 编程比较容易。
- Guava提供的通用公共类封装了公共的操作方方法,不需要提供Future和ListenableFuture的扩展方法。
接口
传统JDK中的Future通过异步的方式计算返回结果:在多线程运算中可能或者可能在没有结束返回结果,Future是运行中的多线程的一个引用句柄,确保在服务执行返回一个Result。
ListenableFuture可以允许你注册回调方法(callbacks),在运算(多线程执行)完成的时候进行调用, 或者在运算(多线程执行)完成后立即执行。这样简单的改进,使得可以明显的支持更多的操作,这样的功能在JDK concurrent中的Future是不支持的。
ListenableFuture 中的基础方法是addListener(Runnable, Executor), 该方法会在多线程运算完的时候,指定的Runnable参数传入的对象会被指定的Executor执行。
添加回调(Callbacks)
多数用户喜欢使用 Futures.addCallback(ListenableFuture<V>, FutureCallback<V>, Executor)的方式, 或者 另外一个版本version(译者注:addCallback(ListenableFuture<V> future,FutureCallback<? super V> callback)),默认是采用 MoreExecutors.sameThreadExecutor()线程池, 为了简化使用,Callback采用轻量级的设计. FutureCallback<V> 中实现了两个方法:
- onSuccess(V),在Future成功的时候执行,根据Future结果来判断。
- onFailure(Throwable), 在Future失败的时候执行,根据Future结果来判断。
ListenableFuture的创建
对应JDK中的 ExecutorService.submit(Callable) 提交多线程异步运算的方式,Guava 提供了ListeningExecutorService 接口, 该接口返回 ListenableFuture 而相应的 ExecutorService 返回普通的 Future。将 ExecutorService 转为 ListeningExecutorService,可以使用MoreExecutors.listeningDecorator(ExecutorService)进行装饰。
01
|
ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool( 10 ));
|
02
|
ListenableFuture explosion = service.submit( new Callable() {
|
03
|
public Explosion call() {
|
04
|
return pushBigRedButton();
|
07
|
Futures.addCallback(explosion, new FutureCallback() {
|
08
|
// we want this handler to run immediately after we push the big red button!
|
09
|
public void onSuccess(Explosion explosion) {
|
10
|
walkAwayFrom(explosion);
|
12
|
public void onFailure(Throwable thrown) {
|
13
|
battleArchNemesis(); // escaped the explosion!
|
另外, 假如你是从 FutureTask转换而来的, Guava 提供ListenableFutureTask.create(Callable<V>) 和ListenableFutureTask.create(Runnable, V). 和 JDK不同的是, ListenableFutureTask 不能随意被继承(译者注:ListenableFutureTask中的done方法实现了调用listener的操作)。
假如你喜欢抽象的方式来设置future的值,而不是想实现接口中的方法,可以考虑继承抽象类AbstractFuture<V> 或者直接使用 SettableFuture 。
假如你必须将其他API提供的Future转换成 ListenableFuture,你没有别的方法只能采用硬编码的方式JdkFutureAdapters.listenInPoolThread(Future) 来将 Future 转换成 ListenableFuture。尽可能地采用修改原生的代码返回 ListenableFuture会更好一些。
Application
使用ListenableFuture 最重要的理由是它可以进行一系列的复杂链式的异步操作。
1
|
ListenableFuture rowKeyFuture = indexService.lookUp(query);
|
2
|
AsyncFunction<RowKey, QueryResult> queryFunction =
|
3
|
new AsyncFunction<RowKey, QueryResult>() {
|
4
|
public ListenableFuture apply(RowKey rowKey) {
|
5
|
return dataService.read(rowKey);
|
8
|
ListenableFuture queryFuture = Futures.transform(rowKeyFuture, queryFunction, queryExecutor);
|
其他更多的操作可以更加有效的支持而JDK中的Future是没法支持的.
不同的操作可以在不同的Executors中执行,单独的ListenableFuture 可以有多个操作等待。
当一个操作开始的时候其他的一些操作也会尽快开始执行–“fan-out”–ListenableFuture 能够满足这样的场景:促发所有的回调(callbacks)。反之更简单的工作是,同样可以满足“fan-in”场景,促发ListenableFuture 获取(get)计算结果,同时其它的Futures也会尽快执行:可以参考 the implementation of Futures.allAsList 。(译者注:fan-in和fan-out是软件设计的一个术语,可以参考这里:http://baike.baidu.com/view/388892.htm#1或者看这里的解析Design Principles: Fan-In vs Fan-Out,这里fan-out的实现就是封装的ListenableFuture通过回调,调用其它代码片段。fan-in的意义是可以调用其它Future)
方法
|
描述
|
参考
|
transform(ListenableFuture<A>, AsyncFunction<A, B>, Executor)*
|
返回一个新的ListenableFuture ,该ListenableFuture 返回的result是由传入的AsyncFunction 参数指派到传入的 ListenableFuture中.
|
transform(ListenableFuture<A>, AsyncFunction<A, B>)
|
transform(ListenableFuture<A>, Function<A, B>, Executor)
|
返回一个新的ListenableFuture ,该ListenableFuture 返回的result是由传入的Function 参数指派到传入的 ListenableFuture中.
|
transform(ListenableFuture<A>, Function<A, B>)
|
allAsList(Iterable<ListenableFuture<V>>)
|
返回一个ListenableFuture ,该ListenableFuture 返回的result是一个List,List中的值是每个ListenableFuture的返回值,假如传入的其中之一fails或者cancel,这个Future fails 或者canceled
|
allAsList(ListenableFuture<V>...)
|
successfulAsList(Iterable<ListenableFuture<V>>)
|
返回一个ListenableFuture ,该Future的结果包含所有成功的Future,按照原来的顺序,当其中之一Failed或者cancel,则用null替代
|
successfulAsList(ListenableFuture<V>...)
|
AsyncFunction<A, B> 中提供一个方法ListenableFuture<B> apply(A input),它可以被用于异步变换值。
1
|
List<ListenableFuture> queries;
|
2
|
// The queries go to all different data centers, but we want to wait until they're all done or failed.
|
4
|
ListenableFuture<List> successfulQueries = Futures.successfulAsList(queries);
|
6
|
Futures.addCallback(successfulQueries, callbackOnSuccessfulQueries);
|
CheckedFuture
Guava也提供了 CheckedFuture<V, X extends Exception> 接口。CheckedFuture 是一个ListenableFuture ,其中包含了多个版本的get 方法,方法声明抛出检查异常.这样使得创建一个在执行逻辑中可以抛出异常的Future更加容易 。将 ListenableFuture 转换成CheckedFuture,可以使用 Futures.makeChecked(ListenableFuture<V>, Function<Exception, X>)。
原创文章,转载请注明: 转载自并发编程网 – ifeve.com本文链接地址: google Guava包的ListenableFuture解析
from: http://ifeve.com/google-guava-listenablefuture/
google Guava包的ListenableFuture解析相关推荐
- 一篇让你熟练掌握Google Guava包(全网最全)
Google Guava guava开源库的地址:https://github.com/google/guava 概述 工具类 就是封装平常用的方法,不需要你重复造轮子,节省开发人员时间,提高工作效率 ...
- com.google.guava包里面的相关简单方法
pom坐标 <dependency><groupId>com.google.guava</groupId><artifactId>guava</a ...
- Google guava cache源码解析1--构建缓存器(3)
此文已由作者赵计刚授权网易云社区发布. 欢迎访问网易云社区,了解更多网易技术产品运营经验. 下面介绍在LocalCache(CacheBuilder, CacheLoader)中调用的一些方法: Ca ...
- Google guava cache源码解析1--构建缓存器(2)
此文已由作者赵计刚授权网易云社区发布. 欢迎访问网易云社区,了解更多网易技术产品运营经验. CacheBuilder-->maximumSize(long size) /*** 指定cache中 ...
- google Guava包RateLimiter使用最佳实践
以下是使用Guava RateLimiter的最佳实践: 1 创建RateLimiter对象的最佳实践 在创建RateLimiter对象时,建议使用静态工厂方法来创建,因为它提供了更清晰的API,并且 ...
- 【编程实践】Google Guava 极简教程
前言 Guava 工程包含了若干被 Google 的 Java 项目广泛依赖 的核心库,我们希望通过此文档为 Guava 中最流行和最强大的功能,提供更具可读性和解释性的说明. 适用人群 本教程是基础 ...
- Google Guava官方教程(中文版)gu
Google Guava官方教程(中文版) 原文链接 译文链接 译者: 沈义扬,罗立树,何一昕,武祖 校对:方腾飞 引言 Guava工程包含了若干被Google的 Java项目广泛依赖 的核心库, ...
- Java类库Google Guava学习
参考 官网 https://github.com/google/guava Google Guava官方教程(中文版) | 并发编程网 – ifeve.com 一篇让你熟练掌握Google Guava ...
- Google Guava并发– ListenableFuture
在上一篇文章中,我介绍了使用番石榴库中com.google.common.util.concurrent包中的Monitor类. 在本文中,我将继续介绍Guava并发实用程序,并讨论Listenabl ...
最新文章
- 修正r s分析法matlab程序,关于R/S分析程序用法
- 采购申请的处理流程 --- 责任链模式
- VC6.0使用中遇到的一些问题
- cas无法使用_一文彻底搞懂CAS实现原理
- Iterator模式
- Bailian2713 肿瘤面积【基础】
- python发音1001python发音-Python学习笔记Day3 - Python运算符
- Android中需要了解的数据结构(一)
- LintCode-颜色分类
- linux下如何查看tlq服务,谁能跟我讲解一下bashrc?
- 冒险岛2计算机内存不足建议使用,冒险岛2游戏设置详解 低配电脑如何流畅运行冒险岛2...
- mysql MMM方案
- android 高度百分比,Android 屏幕适配-百分比布局适配
- STM32CubeMX学习笔记(50)——USB接口使用(DFU固件升级)
- 深圳金证股份面试的经历
- 高级中学计算机配置标准,江苏省高级中学艺术装备标准
- TvRecyclerView
- 单链表的基本操作----------头插法/尾插法建立链表
- 蓝屏代码:DRIVR_UNLOADED_WITHOUT_CANCELLING_PENDING_OPERATIONS
- IP 地址和子网掩码
热门文章
- java 文件读写demo
- [Security] Automatically adding CSRF tokens to ajax calls when using jQuery--转
- 9种高性能高可用高并发的技术架构
- Transformer 详解
- 有的人在25岁时就死了,但在75岁时才被埋葬:周鸿祎
- vue 项目引用static目录资源_Vue2.0项目入门 — 静态资源目录src/assets和static/区别...
- C语言结构体-大小,对齐,填充,使用及其他
- 解决Mac上VSCdoe断点失效问题
- 白话Elasticsearch73_ES生产集群中的索引管理02
- Spring4.X系列之IOC