google Guava包的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 中实现了两个方法:
ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));
另外, 假如你是从 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 最重要的理由是它可以进行一系列的复杂链式的异步操作。
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)
// The queries go to all different data centers, but we want to wait until theyre all done or failed.
Google Guava之Joiner 日常开发中,我们经常需要将几个字符串,或者字符串数组、列表之类的数据,拼接成一个以指定符号分隔各个元素的字符串,比如把[1, 2, 3]拼接成 1-2-3 ,如果自己实现的话,基本上就需要编写循环去实现这个功能,代码就变得晦涩起来。
ali清英 方腾飞,花名清英,英文名kiral,并发编程网创始人,支付宝技术专家,《Java并发编程的艺术》作者。
相关文章
- noip2018提高组初赛解析_noip小学组
- 直接下载google play应用-APK Downloader
- google软件测试之道_gtest测试框架
- 【Google Play】IARC 年龄分级 ( IARC 国际年龄分级联盟 | Google Play 设置应用年龄分级 )
- jQuery Google Charts—-一个封装google chart api的jquery插件详解编程语言
- 为Linux服务器的SSH登录启用Google两步验证
- 谷歌推出的安卓文件管理器Files by Google新增旧截图检测和清理功能
- Google 开源 Docker 镜像差异分析工具 container
- 谷歌冻结 Google Code 服务 明年1月25日全面关闭该服务
- Google Chrome 46 稳定版发布:不再警示微小错误的 HTTPS 链接
- 解析:Google开源的“Show and Tell”,是如何让机器“看图说话”的?
- Google Talk是Google 的即时通讯方式,简称Gtalk。它可以进行文字 google talk聊天以及电脑对电脑的语音连接通话。Google此举进一步激化了它和雅虎,微软以及美国在线之间的竞争
- 谷歌大脑撰文解析 AutoML:神经网络如何自行设计神经架构? | Google I/O 2017
- 三星或正在研发第二款Bixby智能音箱,对标Google Home Mini面向低端市场
- Google Daydream大牛解析:如何打造舒适的VR场景?(二)