java中CompletableFuture的使用方法是什么

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

　　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的使用方法是什么”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！