为什么收不到自己网站,百度指数可以查询多长时间的,wordpress会员文章内容,去除wordpressGuava中的ListenableFuture试图为Future对象定义一致的API#xff0c;以注册完成回调。 通过在Future完成时添加回调的功能#xff0c;我们可以异步有效地响应传入的事件。 如果您的应用程序与许多将来的对象高度并发#xff0c;我强烈建议您尽可能使用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 ListenableFutureString future pool.submit(new CallableString() {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 。 我们还没有介绍但是FutureT必须以某种方式处理异步计算期间发生的异常。 此类异常包含在从get()引发的ExecutionException 因此在记录期间调用getCause() get() 。 最后请注意正在使用MoreExecutors.sameThreadExecutor() 。 这是一个方便的抽象您可以使用每API一些想要使用的时间Executor / ExecutorService 大概线程池而你的罚款使用当前线程。 这在单元测试期间特别有用–即使您的生产代码使用异步任务在测试期间您也可以从同一线程运行所有内容。 不管它多么方便整个代码看起来都有些混乱。 幸运的是在梦幻般的Futures类中有一个简单的实用程序方法 Futures.addCallback(future, new FutureCallbackString() {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() 它是将普通FutureV转换为ListenableFutureV的适配器。 但是请记住一旦开始使用addListener() 每个这样的适配器将只需要一个线程即可工作因此此解决方案根本无法扩展因此应避免使用它。 FutureString future //...
ListenableFutureString listenableFuture JdkFutureAdapters.listenInPoolThread(future); 一旦了解了基础知识我们就可以深入探究听期货的最大优势 转型和连锁 。 这是高级材料已被警告。 参考 NoBlogDefFound博客中来自JCG合作伙伴 Tomasz Nurkiewicz的番石榴中的ListenableFuture 。 翻译自: https://www.javacodegeeks.com/2013/02/listenablefuture-in-guava.html
