日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

[[420499]]

創(chuàng)新互聯(lián)建站主營阿圖什網(wǎng)站建設的網(wǎng)絡公司,主營網(wǎng)站建設方案,成都app開發(fā),阿圖什h5小程序開發(fā)搭建,阿圖什網(wǎng)站營銷推廣歡迎阿圖什等地區(qū)企業(yè)咨詢

在對類的命名這篇長文中，我們提到了Future和Promise。

Future相當于一個占位符，代表一個操作將來的結果。一般通過get可以直接阻塞得到結果，或者讓它異步執(zhí)行然后通過callback回調(diào)結果。

但如果回調(diào)中嵌入了回調(diào)呢?如果層次很深，就是回調(diào)地獄。Java中的CompletableFuture其實就是Promise，用來解決回調(diào)地獄問題。Promise是為了讓代碼變得優(yōu)美而存在的。

有多優(yōu)美?這么說吧，一旦你使用了CompletableFuture，就會愛不釋手，就像初戀女友一樣，天天想著她。

一系列靜態(tài)方法

從它的源代碼中，我們可以看到，CompletableFuture直接提供了幾個便捷的靜態(tài)方法入口。其中有run和supply兩組。

run的參數(shù)是Runnable，而supply的參數(shù)是Supplier。前者沒有返回值，而后者有，否則沒有什么兩樣。

這兩組靜態(tài)函數(shù)，都提供了傳入自定義線程池的功能。如果你用的不是外置的線程池，那么它就會使用默認的ForkJoin線程池。默認的線程池，大小和用途你是控制不了的，所以還是建議自己傳遞一個。

典型的代碼，寫起來是這個樣子。

 
 
 
 

  
  
  
  
CompletableFuture future = CompletableFuture.supplyAsync(()->{ 
  
  
  
  
 return "test"; 
  
  
  
  
}); 
  
  
  
  
String result = future.join(); 
 
 
 
 

拿到CompletableFuture后，你就可以做更多的花樣。

這些花樣有很多

我們說面說了，CompletableFuture的主要作用，就是讓代碼寫起來好看。配合Java8之后的stream流，可以把整個計算過程抽象成一個流。前面任務的計算結果，可以直接作為后面任務的輸入，就像是管道一樣。

 
 
 
 

  
  
  
  
thenApply 
  
  
  
  
thenApplyAsync 
  
  
  
  
thenAccept 
  
  
  
  
thenAcceptAsync 
  
  
  
  
thenRun 
  
  
  
  
thenRunAsync 
  
  
  
  
thenCombine 
  
  
  
  
thenCombineAsync 
  
  
  
  
thenCompose 
  
  
  
  
thenComposeAsync 
 
 
 
 

比如，下面代碼的執(zhí)行結果是99，并不因為是異步就打亂代碼執(zhí)行的順序了。

 
 
 
 

  
  
  
  
CompletableFuture cf = CompletableFuture.supplyAsync(() -> 10) 
  
  
  
  
                .thenApplyAsync((e) -> { 
  
  
  
  
                    try { 
  
  
  
  
                        Thread.sleep(10000); 
  
  
  
  
                    } catch (InterruptedException ex) { 
  
  
  
  
                        ex.printStackTrace(); 
  
  
  
  
                    } 
  
  
  
  
                    return e * 10; 
  
  
  
  
                }).thenApplyAsync(e -> e - 1); 
  
  
  
  
 
  
  
  
  
cf.join(); 
  
  
  
  
System.out.println(cf.get()); 
 
 
 
 

同樣的，函數(shù)的作用還要看then后面的動詞。

• apply 有入?yún)⒑头祷刂?，入?yún)榍爸萌蝿盏妮敵?/li>
• accept 有入?yún)o返回值，會返回CompletableFuture
• run 沒有入?yún)⒁矝]有返回值，同樣會返回CompletableFuture
• combine 形成一個復合的結構，連接兩個CompletableFuture，并將它們的2個輸出結果，作為combine的輸入
• compose 將嵌套的CompletableFuture平鋪開，用來串聯(lián)兩個CompletableFuture

when和handle

上面的函數(shù)列表，其實還有很多。比如：

 
 
 
 

  
  
  
  
whenComplete 
 
 
 
 

when的意思，就是任務完成時候的回調(diào)。比如我們上面的例子，打算在完成任務后，輸出一個done。它也是屬于只有入?yún)]有出參的范疇，適合放在最后一步進行觀測。

 
 
 
 

  
  
  
  
CompletableFuture cf = CompletableFuture.supplyAsync(() -> 10) 
  
  
  
  
                .thenApplyAsync((e) -> { 
  
  
  
  
                    try { 
  
  
  
  
                        Thread.sleep(1000); 
  
  
  
  
                    } catch (InterruptedException ex) { 
  
  
  
  
                        ex.printStackTrace(); 
  
  
  
  
                    } 
  
  
  
  
                    return e * 10; 
  
  
  
  
                }).thenApplyAsync(e -> e - 1) 
  
  
  
  
                .whenComplete((r, e)->{ 
  
  
  
  
                    System.out.println("done"); 
  
  
  
  
                }) 
  
  
  
  
                ; 
  
  
  
  
 
  
  
  
  
cf.join(); 
  
  
  
  
System.out.println(cf.get()); 
 
 
 
 

handle和exceptionally的作用，和whenComplete是非常像的。

 
 
 
 

  
  
  
  
public CompletableFuture exceptionally(Function fn); 
  
  
  
  
 
  
  
  
  
public  CompletionStage handle(BiFunction fn); 
 
 
 
 

 
 
 
 

  
  
  
  
CompletableFuture cf = CompletableFuture.supplyAsync(() -> 10) 
  
  
  
  
                .thenApplyAsync(e->e/0) 
  
  
  
  
                .thenApplyAsync(e -> e - 1) 
  
  
  
  
                .exceptionally(ex->{ 
  
  
  
  
                    System.out.println(ex); 
  
  
  
  
                    return -1; 
  
  
  
  
                }); 
  
  
  
  
 
  
  
  
  
cf.join(); 
  
  
  
  
System.out.println(cf.get()); 
 
 
 
 

 
 
 
 

  
  
  
  
ExecutorService executor = Executors.newFixedThreadPool(5); 
  
  
  
  
 
  
  
  
  
CountDownLatch countDown = new CountDownLatch(requests.size()); 
  
  
  
  
for(Request request:requests){ 
  
  
  
  
    executor.execute(()->{ 
  
  
  
  
        try{ 
  
  
  
  
        //some opts 
  
  
  
  
        }finally{ 
  
  
  
  
            countDown.countDown(); 
  
  
  
  
        } 
  
  
  
  
    }); 
  
  
  
  
} 
  
  
  
  
countDown.await(200,TimeUnit.MILLISECONDS); 
 
 
 
 

 
 
 
 

  
  
  
  
ExecutorService executor = Executors.newFixedThreadPool(5); 
  
  
  
  
 
  
  
  
  
List> futureList = requests 
  
  
  
  
    .stream() 
  
  
  
  
    .map(request-> 
  
  
  
  
        CompletableFuture.supplyAsync(e->{ 
  
  
  
  
            //some opts 
  
  
  
  
        },executor)) 
  
  
  
  
    .collect(Collectors.toList()); 
  
  
  
  
 
  
  
  
  
CompletableFuture allCF = CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])); 
  
  
  
  
 
  
  
  
  
allCF.join();