CompletableFuture.join和get

//創(chuàng)建第三個(gè)異步方法    
CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> method1());
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> method2());
CompletableFuture<Boolean> future3 = CompletableFuture.supplyAsync(() -> method3());
//使用CompletableFuture.allOf()方法等待它們?nèi)客瓿?
CompletableFuture<Void> allFutures = CompletableFuture.allOf(future1, future2, future3);
//所有方法完成之后
allFutures.thenRun(() -> {
//使用join()方法獲取每個(gè)CompletableFuture對(duì)象的結(jié)果    
    String result1 = future1.join();
    Integer result2 = future2.join();
    Boolean result3 = future3.join();
    // process results
});

CompletableFuture.join()和CompletableFuture.get()都可以用來獲取CompletableFuture對(duì)象的結(jié)果，但它們之間有一些重要的區(qū)別。

join()方法是CompletableFuture對(duì)象的非阻塞方法，它會(huì)立即返回結(jié)果（如果已經(jīng)計(jì)算完成），或者等待結(jié)果計(jì)算完成后返回結(jié)果。如果結(jié)果還沒有算完成，join()方法會(huì)拋出一個(gè)CompletionException`異常，這個(gè)異常包含了導(dǎo)致計(jì)算失敗的原因。

get()方法是CompletableFuture對(duì)象的阻塞方法，它會(huì)等待結(jié)果計(jì)算完成后返回結(jié)果。如果結(jié)果還沒有計(jì)算完成，get()方法會(huì)阻塞當(dāng)前線程，直到結(jié)果計(jì)算。如果結(jié)果計(jì)算失敗，get()方法會(huì)拋出一個(gè)ExecutionException異常，這個(gè)異常包含了導(dǎo)致計(jì)算失敗的原因。

因此，join()方法更適合在異步代碼中使用，因它不會(huì)阻塞當(dāng)前線程，而是立即返回結(jié)果或等待結(jié)果計(jì)算完成后返回結(jié)果。而get()方法更適合在同步中使用，因?yàn)樗鼤?huì)阻塞當(dāng)前線程，直到結(jié)果計(jì)算完成。

另外，join()方法比get()方法更快，因?yàn)樗恍枰獟伋鯥nterruptedException異常，這個(gè)異常會(huì)導(dǎo)致線程中斷，從而增加了額的開銷。因此，如果我們不需要處理線程中斷，那么使用join()方法比使用get()方法更快。

CompletableFuture.runAsync和supplyAsync

CompletableFuture.runAsync()和CompletableFuture.supplyAsync()都是用于創(chuàng)建異步任務(wù)的方法。

CompletableFuture.run()方法接受一個(gè)Runnable對(duì)象作為參數(shù)，它會(huì)異步執(zhí)行這個(gè)Runnable對(duì)象，并返回一個(gè)CompletableFuture對(duì)象。由于Runnable對(duì)象沒有返回值，因此CompletableFuture對(duì)象也沒有返回值。

CompletableFuture.supplyAsync()方法接受一個(gè)Supplier對(duì)象作為參數(shù)，它會(huì)異步執(zhí)行這個(gè)Supplier對(duì)象，并返回一個(gè)CompletableFuture對(duì)象。由于Supplier對(duì)象有返回值，因此CompletableFuture對(duì)象也有返回值。

因此，CompletableFuture.runAsync()方法適用于那些沒有返回的異步任務(wù)，而CompletableFuture.supplyAsync()方法適用于那些有返回值的異步任務(wù)。

下面是一個(gè)使用CompletableFuture.runAsync()方法的示例：

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        // do some work
    });    

在這個(gè)示例中，我們創(chuàng)建了一個(gè)CompletableFuture對(duì)象，它異步執(zhí)行了一個(gè)Runnable對(duì)象，這個(gè)Runnable對(duì)象沒有返回值。
下面是一個(gè)使用CompletableFuture.supplyAsync()方法的示例：

 CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
        // do some work
        return "result";
    });

在這個(gè)示例中，我們創(chuàng)建了一個(gè)CompletableFuture對(duì)象，它異步執(zhí)行了一個(gè)Supplier對(duì)象，這個(gè)Supplier對(duì)象有返回值。

總結(jié)，CompletableFuture.runAsync()方法適用于那些沒有返回值的異步任務(wù)，而CompletableFuture.supplyAsync()方法適用于那些有返回值的異步任務(wù)。

到此這篇關(guān)于java中CompletableFuture異步執(zhí)行方法的文章就介紹到這了,更多相關(guān)java CompletableFuture異步執(zhí)行 內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論