一、ListenableFuture 介绍

并发是一个困难问题，但是通过强大和强大的抽象能够显著的简化工作。为了简化问题，Gauva使用ListenableFuture扩展了JDK的Future接口，

**我们强烈建议你在你所有的代码中使用ListenableFuture代替Future，**因为：

• 大多数的Future方法需要它；
• 这比以后更改为ListenableFuture更容易；
• 实用方法的提供者不需要提供Future和ListenableFuture方法的变体；

二、接口

传统的Future代表着异步计算的结果：一个计算可能也可能没有完成生成结果。Future可以是一个程序计算的句柄，一个来自服务的承诺提供给我们一个结果。

ListenableFuture允许你注册一个回调函数，一旦计算是完成或者计算是已经完成，回调函数会立马执行。这个简单的添加能有效的支持多种Future接口不支持的操作。

基础的操作被ListenableFuture添加是通过addListener(Runnable, Executor)，它指定了当Future的计算完成之后，指定的Runnable将会在Executor中执行。

三、添加回调函数

大多数用户更喜欢使用Futures.addCallback(ListenableFuture, FutureCallback, Executor)，一个FutueCallback有两个方法：

• onSuccess(V) 如果future执行成功，基于结果进行执行。
• onFailure(Throwable) 如果future执行失败，基于失败进行执行。

四、创建

相对于JDKExecutorService.submit(Callable) 方法初始化一个异步的计算。Guava提供了一个ListeningExecutorService 接口，它能在任何ExecutorService返回一个正常Future的地方，返回一个ListenableFuture。为了将ExecutorService转换成ListeningExecutorService ，仅需要使用MoreExecutors.listeningDecorator(executorService)：

或者，如果你从一个基于FutureTask的API进行转换，Guava提供了ListenableFutureTask.create(Callable)和ListenableFutureTask.create(Runnable, V) 。并不像JDK，ListenableFutureTask并不意味着直接扩展。

如果您更喜欢设置未来值的抽象而不是实现计算值的方法，请考虑扩展 AbstractFuture<V> 或直接使用 SettableFuture。

如果你必须将另一个API提供的Future转换成ListenableFuture，你没有选择除了使用重量级的JdkFutureAdapters.listenInPoolThread(Future) ，将Future转化成ListenableFuture。无论什么时候，只要有可能，都应该修改源代码去返回一个ListenableFuture。

五、应用

使用ListenableFuture的重要原因是，它让异步的链操作成为可能。

很多有效的其它操作使用ListenableFuture是支持的，而单独使用Future是不支持的。不同的操作能够被不同的Executor执行，并且单个 ListenableFuture 可以有多个等待它的操作。

当多个操作应该在另一个操作开始时立即开始时——“扇出”——ListenableFuture 才起作用：它触发所有请求的回调。通过稍微多一点的工作，我们能“扇入”，或触发ListenableFuture进行计算只要若干个其它的Future执行完（看：Futures.allAsList）。

一个AsyncFunction 提供了一个方法ListenableFuture<B> apply(A a)。它用于异步传输一个值。

六、避免内嵌的Future

上面的代码是不正确的， 因为如果外部Future的取消与外部Future的完成竞争，则该取消不会传播到内部Future。 使用 get() 或侦 听器检查其他Future的失败也是一个常见错误，但除非特别注意，否则从 otherCallable 抛出的异常将被抑制。

为了避免这种情况，Guava 的所有Future处理方法（以及一些来自 JDK）都有 *Async 版本，可以安全地解开这个嵌套：

• Futures.transformAsync(ListenableFuture, AsyncFunction, Executor)
• ExecutorService.submit(Callable)
• Futures.submitAsync(AsyncCallable, Executor)