本篇內容介紹了“java中CompletableFuture的使用方法是什么”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

10年積累的網站建設、成都網站制作經驗，可以快速應對客戶對網站的新想法和需求。提供各種問題對應的解決方案。讓選擇我們的客戶得到更好、更有力的網絡服務。我雖然不認識你，你也不認識我。但先網站設計制作后付款的網站建設流程，更有龍沙免費網站建設讓你可以放心的選擇與我們合作。

java中CompletableFuture的使用

CompletableFuture首先是一個Future，它擁有Future所有的功能，包括獲取異步執行結果，取消正在執行的任務等。

除此之外，CompletableFuture還是一個CompletionStage。

我們看下CompletableFuture的定義：

public class CompletableFuture implements Future, CompletionStage

什么是CompletionStage呢?

在異步程序中，如果將每次的異步執行都看成是一個stage的話，我們通常很難控制異步程序的執行順序，在javascript中，我們需要在回調中執行回調。這就會形成傳說中的回調地獄。

好在在ES6中引入了promise的概念，可以將回調中的回調轉寫為鏈式調用，從而大大的提升了程序的可讀性和可寫性。

同樣的在java中，我們使用CompletionStage來實現異步調用的鏈式操作。

CompletionStage定義了一系列的then*** 操作來實現這一功能。

CompletableFuture作為Future使用

調用CompletableFuture.complete方法可以立馬返回結果，我們看下怎么使用這個方法來構建一個基本的Future：

public Future calculateAsync() throws InterruptedException {CompletableFuture completableFuture= new CompletableFuture<>();Executors.newCachedThreadPool().submit(() -> {Thread.sleep(500);completableFuture.complete("Hello");return null;});return completableFuture;}

上面我們通過調動ExecutorService來提交一個任務從而得到一個Future。如果你知道執行的結果，那么可以使用CompletableFuture的completedFuture方法來直接返回一個Future。

public Future useCompletableFuture(){Future completableFuture =CompletableFuture.completedFuture("Hello");return completableFuture;}

CompletableFuture還提供了一個cancel方法來立馬取消任務的執行：

public Future calculateAsyncWithCancellation() throws InterruptedException {CompletableFuture completableFuture = new CompletableFuture<>();Executors.newCachedThreadPool().submit(() -> {Thread.sleep(500);completableFuture.cancel(false);return null;});return completableFuture;}

如果這個時候調用Future的get方法，將會報CancellationException異常。

Future future = calculateAsyncWithCancellation();future.get(); // CancellationException

異步執行code

CompletableFuture提供了runAsync和supplyAsync的方法，可以以異步的方式執行代碼。

我們看一個runAsync的基本應用，接收一個Runnable參數：

public void runAsync(){CompletableFuture runAsync= CompletableFuture.runAsync(()->{log.info("runAsync");});}

而supplyAsync接受一個Supplier：

public void supplyAsync(){CompletableFuture supplyAsync=CompletableFuture.supplyAsync(()->{return "supplyAsync";});}

他們兩個的區別是一個沒有返回值，一個有返回值。

組合Futures

上面講到CompletableFuture的一個重大作用就是將回調改為鏈式調用，從而將Futures組合起來。

而鏈式調用的返回值還是CompletableFuture，我們看一個thenCompose的例子：

CompletableFuture completableFuture

= CompletableFuture.supplyAsync(() -> "Hello").thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " World"));

thenCompose將前一個Future的返回結果作為后一個操作的輸入。

如果我們想合并兩個CompletableFuture的結果，則可以使用thenCombine：

public void thenCombine(){CompletableFuture completableFuture= CompletableFuture.supplyAsync(() -> "Hello").thenCombine(CompletableFuture.supplyAsync(() -> " World"), (s1, s2) -> s1 + s2));}

如果你不想返回結果，則可以使用thenAcceptBoth：

public void thenAcceptBoth(){CompletableFuture future = CompletableFuture.supplyAsync(() -> "Hello").thenAcceptBoth(CompletableFuture.supplyAsync(() -> " World"),(s1, s2) -> System.out.println(s1 + s2));}

thenApply() 和 thenCompose()的區別

thenApply()和thenCompose()兩個方法都可以將CompletableFuture連接起來，但是兩個有點不一樣。

thenApply()接收的是前一個調用返回的結果，然后對該結果進行處理。

thenCompose()接收的是前一個調用的stage，返回flat之后的的CompletableFuture。

簡單點比較，兩者就像是map和flatMap的區別。

并行執行任務

當我們需要并行執行任務時，通常我們需要等待所有的任務都執行完畢再去處理其他的任務，那么我們可以用到CompletableFuture.allOf方法：

public void allOf(){CompletableFuture future1= CompletableFuture.supplyAsync(() -> "Hello");CompletableFuture future2= CompletableFuture.supplyAsync(() -> "Beautiful");CompletableFuture future3= CompletableFuture.supplyAsync(() -> "World");CompletableFuture combinedFuture= CompletableFuture.allOf(future1, future2, future3);}

allOf只保證task全都執行，而并沒有返回值，如果希望帶有返回值，我們可以使用join：

public void join(){CompletableFuture future1= CompletableFuture.supplyAsync(() -> "Hello");CompletableFuture future2= CompletableFuture.supplyAsync(() -> "Beautiful");CompletableFuture future3= CompletableFuture.supplyAsync(() -> "World");String combined = Stream.of(future1, future2, future3).map(CompletableFuture::join).collect(Collectors.joining(" "));}

上面的程序將會返回：“Hello Beautiful World”。

異常處理

如果在鏈式調用的時候拋出異常，則可以在最后使用handle來接收：

北海房價走勢 http://house.bh.goufang.com/lpfangjia/

public void handleError(){String name = null;CompletableFuture completableFuture= CompletableFuture.supplyAsync(() -> {if (name == null) {throw new RuntimeException("Computation error!");}return "Hello, " + name;}).handle((s, t) -> s != null ? s : "Hello, Stranger!");}

這和Promise中的catch方法使用類似。

“java中CompletableFuture的使用方法是什么”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注創新互聯網站，小編將為大家輸出更多高質量的實用文章！

分享名稱：java中CompletableFuture的使用方法是什么
網站網址：http://vcdvsql.cn/article24/gjghce.html

成都網站建設公司_創新互聯，為您提供全網營銷推廣、網站設計公司、App設計、自適應網站、做網站、網站導航

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯