guava ListenableFuture實作多線程

最近項目中多線程的實作使用了ListenableFuture，是以就研究了下，使用ListenableFuture接口使java的多線程實作（參考另外一篇java多線程實作）變的簡單

jar包引入

首先在項目pom.xml檔案中引入

<dependency>
      <groupId>com.google.guava</groupId>
       <artifactId>guava</artifactId>
       <version>21.0</version>
   </dependency>
           

ListenableFuture接口拓展了java.util.concurrent.Future，增加了addListener方法，該方法會在多線程運算完的時候，指定的Runnable參數傳入的對象會被指定的Executor執行

ListenableFuture的實作多線程

Guava 提供了ListeningExecutorService 接口, 調用submit傳回 ListenableFuture，

線程池可以使用MoreExecutors.listeningDecorator(ExecutorService)方法将 ExecutorService 轉為 ListeningExecutorService

參考之前java多線程的部落格 實作如下

public class MyCallable implements Callable<String>{
    private String taskName;
    MyCallable(String taskName) {
        this.taskName = taskName;
    }
    // 這裡寫具體的業務邏輯
    @Override
    public String call() throws Exception {
        return taskName;
    }
}

int poolSize = 10;
// 建立大小為10的 線程池ExecutorService
ExecutorService pool = Executors.newFixedThreadPool(poolSize);

// 建立ListeningExecutorService
ListeningExecutorService service = MoreExecutors.listeningDecorator(pool);

// 建立任務
List<ListenableFuture<String>> taskList = new ArrayList<ListenableFuture<String>>();
for (int i = 0; i < 10; i++) {
    Callable c = new MyCallable("task "+i);
    // 執行任務并擷取ListenableFuture對象
    ListenableFuture f = service.submit(c);
    // 添加到任務清單
    taskList.add(f);
}

// 使用guava包中的Futures的successfulAsList 方法建立一個ListenableFuture包含上面taskList的執行結果
ListenableFuture<List<String>> listFuture = Futures.successfulAsList(taskList)    

try {
    // 通過listFuture.get()獲得所有執行傳回結果 ，do something
    ...
}catch (Exception e){
    // 錯誤處理
    ...
}finally {
        pool.shutdown();
}
           

上面的寫法跟java使用Callable接口、ExecutorService接口和Future接口實作有傳回結果的多線程 方式很類似

添加回調方法

如果我們希望task執行完的時候回調指定方法，可以使用 Futures.addCallback(ListenableFuture, FutureCallback, Executor)

// 這個也可以單獨對f 增加回調
Futures.addCallback(listFuture,new FutureCallback<List<String>>(){
            public void onSuccess(List<String> result){
                // do something
            }

            public void onFailure(Throwable t){
            }

        });