Java中的完整形式通過(guò)比傳統(tǒng)的未來(lái)界面具有更大的靈活性來(lái)簡(jiǎn)化異步編程。 1. It allows manual completion of tasks using complete(), 2. supports async execution via runAsync() or supplyAsync(), 3. enables chaining operations with thenApply (transforms result), thenAccept (consumes result), and thenRun (runs after completion), 4. combines futures using thenCompose (chaining futures) and thenCombine (merging results), 5. handles errors via exceptionally （後備值）和句柄（自定義錯(cuò)誤/結(jié)果處理），以及6。提供線程控制方法的異步版本，增強(qiáng)異步工作流中的並行性和可讀性。

CompletableFuture是Java 8中引入的java.util.concurrent軟件包的一類(lèi)。它旨在通過(guò)允許您編寫(xiě)與較舊的Future界面更加干淨(jìng)，更靈活地處理期貨（異步計(jì)算結(jié)果）的非障礙代碼來(lái)使異步編程更容易。

CompletableFuture背後的主要思想是，它使您可以更多地控制任務(wù)如何鏈接和組合，包括處理異常，組合多個(gè)期貨，並指定哪個(gè)線程應(yīng)運(yùn)行下一步。

基本用途：創(chuàng)建和完成期貨

您可以通過(guò)幾種方式創(chuàng)建一個(gè)CompletableFuture ：

• 使用complete()手動(dòng)完成它
• 使用runAsync()或supplyAsync()等方法運(yùn)行異步任務(wù)

例如：

完整future <string> future = ploteablefuture.supplyasync（（） - > {
    //模擬長(zhǎng)期運(yùn)行的任務(wù)
    嘗試 {
        thread.sleep（1000）;
    } catch（InterruptedException e）{}
    返回“你好”；
}）;

future.thenaccept（結(jié)果 - > system.out.println（“結(jié)果：”結(jié)果））;

這設(shè)置了一個(gè)背景任務(wù)，該任務(wù)在一秒鐘後返回“ Hello”，然後在完成後將其打印。

如果您想手動(dòng)完成未來(lái)（例如，用於測(cè)試或自定義邏輯），則可以做：

完整的future <integer>手動(dòng)future = new plotebleableFuture <>（）;
hanualfuture.complete（42）;
手動(dòng)圖。 //打印42

與thenApply ， thenAccept和thenRun的鏈接操作

CompletableFuture的最大優(yōu)勢(shì)之一是能夠無(wú)需阻止線程的鏈操作。

這是每種方法的工作原理：

• thenApply結(jié)果轉(zhuǎn)換
• thenAccept accept消耗結(jié)果，但沒(méi)有返回任何東西
• thenRun列入完成後運(yùn)行一些代碼，忽略結(jié)果

例子：

完整的future <integer> future = ploteablefuture.supplyasync（（） - >“蘋(píng)果”）
    。
    。 // 5變?yōu)?0

future.thenaccept（system.out :: println）; //打印10

除非您指定其他執(zhí)行程序，否則這些操作通常是在完成上一個(gè)將來(lái)的同一線程上運(yùn)行的。

將期貨與thenCompose和thenCombine結(jié)合在一起

在使用多個(gè)異步步驟時(shí)，兩個(gè)關(guān)鍵方法是：

• thenCompose當(dāng)您有一個(gè)未來(lái)的未來(lái)時(shí)，請(qǐng)使用它
• thenCombine - 當(dāng)您想結(jié)合兩個(gè)獨(dú)立未來(lái)的結(jié)果時(shí)使用此功能

例如：

完整的future <integer> future1 = ploteableFuture.supplyAsync（（（） - > 10）;
完整的future <integer> future2 = ploteablefuture.supplyasync（（（） - > 20）;

//結(jié)合兩個(gè)結(jié)果
Future1.thencombine（未來(lái)2，（a，b） - > ab）
       .thenaccept（system.out :: println）; //打印30

如果您將在未來(lái)的未來(lái)返回未來(lái)：

完整future <integer> compose = ploteablefuture.supplyasync（（） - > 5）
    。

組合。 //打印10

用exceptionally處理錯(cuò)誤並handle

事情並不總是順利進(jìn)行。您可以使用以下方式處理異常

• exceptionally - 如果發(fā)生錯(cuò)誤，則提供後備值
• handle - 讓您檢查結(jié)果和異常，然後選擇要退還的內(nèi)容

例子：

完整future <integer> fressyfuture = ploteablefuture.supplyasync（（） - > {
    如果（true）拋出新的RuntimeException（“ OOPS！”）;
    返回100;
}）;

故障
    。
        system.out.println（“發(fā)生錯(cuò)誤：” ex.getMessage（））;
        返回0; //後備值
    }））
    .thenaccept（system.out :: println）; //打印0

使用handle可以更靈活：

完整的future <integer> andled = fressyfuture.handle（（結(jié)果，ex） - > {
    如果（ex！= null）{
        system.out.println（“處理錯(cuò)誤：” ex.getMessage（））;
        返回1; // 默認(rèn)
    }
    返回結(jié)果；
}）;

異步版本以更好地控制線程

大多數(shù)方法都帶有異步版本（例如， thenApplyAsync ， thenAcceptAsync ），可允許您指定用於下一個(gè)操作的線程池。

當(dāng)您要避免阻止原始線程或想要並行化工作時(shí)，這很有用。

例子：

完整的future <integer> future = ploteablefuture.supplyasync（（（） - > 10）
    。

這樣可以確保乘法發(fā)生在單獨(dú)的線程池中。

因此，基本上， CompletableFuture可幫助您在Java中編寫(xiě)乾淨(jìng)，可讀和高效的異步代碼。它通過(guò)為您提供鏈條，組合和管理異步任務(wù)的工具來(lái)建立在舊的Future界面之上，而不會(huì)陷入回調(diào)地獄。

那就是它的核心。一旦您習(xí)慣了模式，就不會(huì)太複雜。

以上是什麼是``ploteable future''？的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！