guava笔记-并发

一． ListenableFuture是用来增强Future的功能的。

我们知道Future表示一个异步计算任务，当任务完成时可以得到计算结果。如果我们希望一旦计算完成就拿到结果展示给用户或者做另外的计算，就必须使用另一个线程不断的查询计算状态。这样做，不断代码复杂，而且效率低下。

ListenableFuture，顾名思义，就是可以监听的Future。我们可以为ListenableFuture增加Listener监听器，当任务完成时，直接执行某个线程，或者我们可以直接为ListenableFuture设置回调函数，当任务完成时，自动执行该回调方法。

 

下面我们看看ListenableFuture的实际用法。

（1）怎样得到ListenableFuture对象？

 我们知道ExecutorService.submit(Callable) 会返回Future对象，那么ListeningExecutorService.submit(Callable)会返回ListenableFuture对象。

ListeningExecutorService可以通过MoreExecutors.listeningDecorator(ExecutorService)来得到。

 

（2）增加Listenable功能

方法一：直接添加监听

ListenableFuture. addListener(Runnable listener, Executor executor)

可以为ListenableFuture增加一个监听，当线程计算完成时，自动执行一个Runnable线程。

方法二：添加回调方法

Futures.addCallback(ListenableFuture, new FutureCallback<T>() {

  public void onSuccess(T t) {

   

  }

  public void onFailure(Throwable thrown) {

   

  }

});

Futures的静态方法addCallback可以为ListenableFuture对象添加回调函数，回调里面可以定义计算成功时和失败时分别的操作。onSuccess里面可以把计算结果做为参数传入。onFailure里面可以把异常做为参数传入。

 

那我们一般应该怎么选择这两种方式呢？建议直接用第二种，因为这种方式可以把计算结果做为参数传入。其实，第二种的内部实现就是用的第一种方式，但是用起来会更加的简洁。

 

（3）ListenableFutureTask

我们知道，FutureTask实现了Future和Runnable接口。

FutureTask有2个构造方法：

FutureTask(Callable<V> callable)   

创建一个 FutureTask，一旦运行就执行给定的 Callable。  

FutureTask(Runnable runnable, V result)   

创建一个 FutureTask，一旦运行就执行给定的 Runnable，并安排成功完成时 get 返回给定的结果

 

 Thread thread = new Thread(futureTask);  

thread.start();

当futureTask被某个线程执行时，就会自动执行Callable或者Runnable，Callable的call方法返回计算结果，对应Runnable作为参数的版本，另一个参数V result将作为结果进行返回。

当计算完成时，futureTask.get()方法就会返回这个结果。

 

可以看到，这段代码很复杂，而且计算完成时缺乏回调机制。ListenableFutureTask正是为了解决这些问题。ListenableFutureTask同样有2个版本的方法。

ListenableFutureTask.create(Callable<V>)

ListenableFutureTask.create(Runnable, V)

很简单，这2个方法都返回ListenableFutureTask<V>对象，然后就可以用之前所说的方式直接添加回调函数或者回调接口。

 

（4）返回值固定，不需要计算时

有时候，我们的Future不需要实现一个方法来计算返回值，而只需要返回一个固定值来做为返回值，那么可以直接使用 SettableFuture，或者跟 SettableFuture 一样，自己来继承AbstractFuture<V>。

SettableFuture提供了2个方法，分别用来设置成功时的返回值，或者失败时抛出的异常。

booleanset(V value)

booleansetException(Throwable throwable)

另外还有静态方法create()会构造一个初始状态的SettableFuture对象。

示例代码：

SettableFuture<Integer> future = SettableFuture.create();

future.set(100);//自己根据业务逻辑，来设置返回值

// or future.setException(new Throwable()); //或者计算失败，抛出异常

Futures.addCallback(future, new FutureCallback<Integer>() {

@Override

public void onSuccess(Integer result) {

 

}

@Override

public void onFailure(Throwable t) {

 

}

});