日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

[[420499]]

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

在對(duì)類(lèi)的命名這篇長(zhǎng)文中，我們提到了Future和Promise。

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

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

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

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

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

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

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

典型的代碼，寫(xiě)起來(lái)是這個(gè)樣子。

 
 
 
 

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

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

這些花樣有很多

我們說(shuō)面說(shuō)了，CompletableFuture的主要作用，就是讓代碼寫(xiě)起來(lái)好看。配合Java8之后的stream流，可以把整個(gè)計(jì)算過(guò)程抽象成一個(gè)流。前面任務(wù)的計(jì)算結(jié)果，可以直接作為后面任務(wù)的輸入，就像是管道一樣。

 
 
 
 

  
  
  
  
thenApply 
  
  
  
  
thenApplyAsync 
  
  
  
  
thenAccept 
  
  
  
  
thenAcceptAsync 
  
  
  
  
thenRun 
  
  
  
  
thenRunAsync 
  
  
  
  
thenCombine 
  
  
  
  
thenCombineAsync 
  
  
  
  
thenCompose 
  
  
  
  
thenComposeAsync 
 
 
 
 

比如，下面代碼的執(zhí)行結(jié)果是99，并不因?yàn)槭钱惒骄痛騺y代碼執(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后面的動(dòng)詞。

• apply 有入?yún)⒑头祷刂?，入?yún)榍爸萌蝿?wù)的輸出
• accept 有入?yún)o(wú)返回值，會(huì)返回CompletableFuture
• run 沒(méi)有入?yún)⒁矝](méi)有返回值，同樣會(huì)返回CompletableFuture
• combine 形成一個(gè)復(fù)合的結(jié)構(gòu)，連接兩個(gè)CompletableFuture，并將它們的2個(gè)輸出結(jié)果，作為combine的輸入
• compose 將嵌套的CompletableFuture平鋪開(kāi)，用來(lái)串聯(lián)兩個(gè)CompletableFuture

when和handle

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

 
 
 
 

  
  
  
  
whenComplete 
 
 
 
 

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

 
 
 
 

  
  
  
  
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();