宁波做百度网站,怎么注册一个公司网站,建设厅网站业绩备案公示期,图片处理软件guava 并发在上一篇文章中#xff0c;我介绍了使用Guava库中com.google.common.util.concurrent包中的Monitor类的方法。 在这篇文章中#xff0c;我将继续介绍Guava并发实用程序#xff0c;并讨论ListenableFuture接口。 ListenableFuture通过添加接受完成侦听器的方法我介绍了使用Guava库中com.google.common.util.concurrent包中的Monitor类的方法。 在这篇文章中我将继续介绍Guava并发实用程序并讨论ListenableFuture接口。 ListenableFuture通过添加接受完成侦听器的方法从java.util.concurrent包扩展了Future接口。 可听的未来 ListenableFuture行为与java.util.concurrent.Future完全相同但是具有方法addCallback(Runnable, ExecutorService)在给定的executor中执行回调。 这是一个例子 ListenableFuture futureTask executorService.submit(callableTask)futureTask.addListener(new Runnable() {Overridepublic void run() {..work after futureTask completed}}, executorService); 如果在添加回调时提交的任务已完成它将立即运行。 使用addCallback方法有一个缺点即Runnable无法访问future产生的结果。 要访问Future的结果您将需要使用FutureCallback 。 FutureCallback FutureCallback接受从Future产生的结果并指定onSuccess和onFailure方法。 这是一个例子 class FutureCallbackImpl implements FutureCallbackString {Overridepublic void onSuccess(String result){.. work with result}Overridepublic void onFailure(Throwable t) {... handle exception}} 通过使用Futures类中的addCallback方法来附加FutureCallback Futures.addCallback(futureTask, futureCallbackImpl); 此时您可能会问当ExecutorService仅返回Futures时如何获取ListenableFuture实例 答案是使用ListenableExecutionService 。 ListenableExecutionService 要使用ListenableExecutionService只需使用对MoreExecutors.listeningDecorator(ExecutorService)的调用来装饰ExecutorService实例例如 ExecutorsService executorService MoreExecutors.listeningDecorator(Executors.newCachedThreadPool()); 结论 借助添加回调无论是Runnable还是处理成功和失败条件的FutureCallback功能 ListenableFuture可能是对您的武器库的宝贵补充。 我创建了一个单元测试使用证明ListenableFuture可以作为一个依据 。 在我的下一个职位我要覆盖Futures类它包含与工作静态方法futures 。 资源资源 番石榴项目首页 ListenableFuture API 样例代码 参考 Google Guava并发–来自我们的JCG合作伙伴 Bill Bejeck的《可编码的随机思考》博客中的ListenableFuture。 翻译自: https://www.javacodegeeks.com/2012/11/google-guava-concurrency-listenablefuture.htmlguava 并发
