番石榴的ListenableFuture
Guava中的ListenableFuture
试图为Future
对象定义一致的API,以注册完成回调。 通过在Future
完成时添加回调的功能,我们可以异步有效地响应传入的事件。 如果您的应用程序与许多将来的对象高度并发,我强烈建议您尽可能使用ListenableFuture
。 从技术上讲, ListenableFuture
通过添加以下简单ListenableFuture
扩展了Future
接口:
void addListener(Runnable listener, Executor executor)
方法。 而已。 如果掌握了ListenableFuture
,则可以注册Runnable
以在有问题的将来完成时立即执行。 您还必须提供将用于执行您的侦听Executor
( ExecutorService
扩展)–这样长时间运行的侦听器不会占用您的工作线程。
让我们付诸行动。 我们将从重构我们的第一个Web ListenableFuture
器示例以使用ListenableFuture
。 幸运的是,在线程池的情况下,只需使用MoreExecutors.listeningDecorator()
将它们包装起来MoreExecutors.listeningDecorator()
:
ListeningExecutorService pool = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));for (final URL siteUrl : topSites) {final ListenableFuture<String> future = pool.submit(new Callable<String>() {@Overridepublic String call() throws Exception {return IOUtils.toString(siteUrl, StandardCharsets.UTF_8);}});future.addListener(new Runnable() {@Overridepublic void run() {try {final String contents = future.get();//...process web site contents} catch (InterruptedException e) {log.error("Interrupted", e);} catch (ExecutionException e) {log.error("Exception in task", e.getCause());}}}, MoreExecutors.sameThreadExecutor());
}
有几个有趣的发现。 首先,请注意ListeningExecutorService
如何包装现有的Executor
。 这类似于ExecutorCompletionService
方法 。 稍后,我们注册自定义Runnable
,以便在每个任务完成时得到通知。 其次,请注意错误处理变得多么丑陋:我们必须处理InterruptedException
(从技术上讲,这应该永远不会发生,因为Future
已经解决,并且get()
永远不会抛出它)和ExecutionException
。 我们还没有介绍,但是Future<T>
必须以某种方式处理异步计算期间发生的异常。 此类异常包含在从get()
引发的ExecutionException
(因此在记录期间调用getCause()
get()
。
最后请注意正在使用MoreExecutors.sameThreadExecutor()
。 这是一个方便的抽象,您可以使用每API一些想要使用的时间Executor
/ ExecutorService
(大概线程池),而你的罚款使用当前线程。 这在单元测试期间特别有用–即使您的生产代码使用异步任务,在测试期间您也可以从同一线程运行所有内容。
不管它多么方便,整个代码看起来都有些混乱。 幸运的是,在梦幻般的Futures
类中有一个简单的实用程序方法:
Futures.addCallback(future, new FutureCallback<String>() {@Overridepublic void onSuccess(String contents) {//...process web site contents}@Overridepublic void onFailure(Throwable throwable) {log.error("Exception in task", throwable);}
});
FutureCallback
是一个更简单的抽象方法,可以解决将来的问题并为您执行异常处理。 如果需要,您仍然可以为侦听器提供自定义线程池。 如果您仍然使用一些仍会返回Future
旧式API,则可以尝试JdkFutureAdapters.listenInPoolThread()
,它是将普通Future<V>
转换为ListenableFuture<V>
的适配器。 但是请记住,一旦开始使用addListener()
,每个这样的适配器将只需要一个线程即可工作,因此此解决方案根本无法扩展,因此应避免使用它。
Future<String> future = //...
ListenableFuture<String> listenableFuture =JdkFutureAdapters.listenInPoolThread(future);
一旦了解了基础知识,我们就可以深入探究听期货的最大优势: 转型和连锁 。 这是高级材料,已被警告。
参考: NoBlogDefFound博客中来自JCG合作伙伴 Tomasz Nurkiewicz的番石榴中的ListenableFuture 。
翻译自: https://www.javacodegeeks.com/2013/02/listenablefuture-in-guava.html
番石榴的ListenableFuture相关推荐
- Java 8:CompletableFuture的权威指南
Java 8即将到来,因此该学习新功能了. 尽管Java 7和Java 6只是次要的发行版,但版本8将向前迈出一大步. 也许太大了? 今天,我将为您详细介绍JDK 8中的新抽象– Completabl ...
- guava 并发_Google Guava并发– ListenableFuture
guava 并发 在上一篇文章中,我介绍了使用Guava库中com.google.common.util.concurrent包中的Monitor类的方法. 在这篇文章中,我将继续介绍Guava并发实 ...
- Google Guava并发– ListenableFuture
在上一篇文章中,我介绍了使用番石榴库中com.google.common.util.concurrent包中的Monitor类. 在本文中,我将继续介绍Guava并发实用程序,并讨论Listenabl ...
- java中对list监听_java – Guava:为ListenableFuture回调和监听器设置默认的Executor
我们的应用程序有许多实现基于ListenableFuture的API的服务,可以调整: public interface MyService { ListenableFuture getMyThing ...
- google Guava包的ListenableFuture解析
原文地址 译者:罗立树 校对:方腾飞 并发编程是一个难题,但是一个强大而简单的抽象可以显著的简化并发的编写.出于这样的考虑,Guava 定义了 ListenableFuture接口并继承了JDK ...
- 使用Spring AOP和番石榴速率限制器的节气门方法
外部服务或API可能有使用限制,或者它们不能失败就无法处理大量请求. 这篇文章解释了如何创建一个基于Spring Framework的方面,该方面可以用来限制使用Guava速率限制器的任何建议方法调用 ...
- stringutils_番石榴分配器vs StringUtils
stringutils 因此,我最近写了一篇关于旧的,可靠的Apache Commons StringUtils的文章 ,该文章引起了很多评论,其中之一是Google Guava提供了更好的连接和拆分 ...
- 忘记番石榴:5个Google库Java开发人员应该知道的
什么是最有用但未知的Google Java库? 如果我们在激烈的黑客马拉松中阻止某人并要求她命名一个受欢迎的Google Java库,那么答案可能就是Guava. 这也就不足为奇了,因为它的主要重点是 ...
- 番石榴条纹类的细粒度并发
这篇文章将介绍如何使用Guava中的Striped类来实现更细粒度的并发. ConcurrentHashMap使用条带化锁定方法来增加并发性,并且Striped类通过赋予我们具有条带化Locks , ...
最新文章
- Flutter 基础布局Widgets之Baseline、AspectRatio详解
- java拷贝文件权限_boto3 copy vs copy_object关于s3中的文件权限ACL
- Linkify介绍 编辑textview超链接
- matlab平面绘图命令
- win10兼容模式怎么设置_win10护眼模式关不掉怎么办
- React开发(162):React关于 this.props.children 总结
- 溢信服务转型之代理商技术培训
- Linux环境下利用句柄恢复Oracle误删除的数据文件
- fullcalendar 只保留周_用枝条扦插橡皮树太浪费,只需一个“叶片”,就能变成一棵橡皮树...
- Ubuntu 20.04桌面美化
- CacheCloud安装配置
- import time python_import time
- 迷宫问题求解(1) 简单迷宫
- echarts贵州地图展示自定义贵安新区
- overflow:auto
- java内存模型作用是什么意思_JMM(Java内存模型)是什么?为什么使用并发?
- linux钉钉-使用playonlinux 可以使用视频会议
- hive窗口函数必备宝典
- 基于深度学习的目标检测算法综述(二)
- linux下16进制编辑器,需要一个好的十六进制编辑器为Linux
热门文章
- sqlserver如何定义一个静态变量_[Bazel]自定义规则实现将多个静态库合并为一个动态库或静态库...
- html模板(base标签,meta标签,禁用浏览器缓存)+JSP自定义标签荔枝
- tomcat(5)servlet容器
- selenium 等待_Selenium等待:内隐,外显,流利和睡眠
- json怎么读取数据库_如何:使用Json插入数据库并从中读取
- spark rest_Spark简介,您的下一个REST Java框架
- java8 streams_Java 8 Streams API:对流进行分组和分区
- openshift k8s_带有DIY的Openshift上的Spring Boot / Java 8 / Tomcat 8
- 使用Java :: Geci生成setter和getter
- java8根据某个id删选_Java 8可选:如何使用它