Gauva使用ListenableFuture介紹說明

一、ListenableFuture 介紹

並發是一個困難問題,但是通過強大和強大的抽象能夠顯著的簡化工作。為瞭簡化問題,Gauva使用ListenableFuture擴展瞭JDK的Future接口,

**我們強烈建議你在你所有的代碼中使用ListenableFuture代替Future,**因為:

  • 大多數的Future方法需要它;
  • 這比以後更改為ListenableFuture更容易;
  • 實用方法的提供者不需要提供FutureListenableFuture方法的變體;

二、接口

傳統的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)

        ListeningExecutorService service =
                MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(
                  Runtime.getRuntime().availableProcessors()));
        ListenableFuture<String> listenableFuture = service.submit(() -> callDemo());
        Futures.addCallback(listenableFuture, new FutureCallback<String>() {
            @Override
            public void onSuccess(String result) {
                System.out.println("Run Ok : " + result);
//                service.shutdown();
            }
            @Override
            public void onFailure(Throwable t) {
                System.out.println("Run Fail: " + t);
            }
        }, service);

或者,如果你從一個基於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)。

方法 描述 延伸
Futures.transformAsync(ListenableFuture, AsyncFunction, Executor) 返回一個新的ListenableFuture,它的結果是應用AsyncFunction。AsyncFunction是對ListenableFuture結果的加工
Futures.transform(ListenableFuture, Function, Executor) 返回一個新的ListenableFuture,它的結果是應用Function。Function是對ListenableFuture結果的加工
Futures.allAsList(Iterable<ListenableFuture<V>>) 返回一個ListenableFuture,它的值是一個list包含瞭每一個輸入輸入future的值。如果任何的future失敗或取消,這個future也失敗或取消。
Futures.successfulAsList(Iterable<ListenableFuture>) 返回一個ListenableFuture,它的值是一個list包含瞭每一個輸入輸入future的值。如果相對應的future失敗或取消,將用null代替。

一個AsyncFunction 提供瞭一個方法ListenableFuture<B> apply(A a)。它用於異步傳輸一個值。

六、避免內嵌的Future

ListenableFuture<ListenableFuture<String>> nestedFuture =
                executorService.submit(() -> otherExecutorService.submit(() -> callDemo())); 

上面的代碼是不正確的, 因為如果外部Future的取消與外部Future的完成競爭,則該取消不會傳播到內部Future。 使用 get() 或偵 聽器檢查其他Future的失敗也是一個常見錯誤,但除非特別註意,否則從 otherCallable 拋出的異常將被抑制。

為瞭避免這種情況,Guava 的所有Future處理方法(以及一些來自 JDK)都有 *Async 版本,可以安全地解開這個嵌套:

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

到此這篇關於Gauva使用ListenableFuture介紹說明的文章就介紹到這瞭,更多相關Gauva ListenableFuture內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: