Java中的完整形式通過比傳統(tǒng)的未來界面具有更大的靈活性來簡化異步編程。 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 （后備值）和句柄（自定義錯誤/結(jié)果處理），以及6。提供線程控制方法的異步版本，增強異步工作流中的并行性和可讀性。

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

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

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

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

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

例如：

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

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

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

如果您想手動完成未來（例如，用于測試或自定義邏輯），則可以做：

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

與thenApply ， thenAccept和thenRun的鏈接操作

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

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

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

例子：

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

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

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

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

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

• thenCompose當(dāng)您有一個未來的未來時，請使用它
• thenCombine - 當(dāng)您想結(jié)合兩個獨立未來的結(jié)果時使用此功能

例如：

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

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

如果您將在未來的未來返回未來：

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

組合。 //打印10

用exceptionally處理錯誤并handle

事情并不總是順利進行。您可以使用以下方式處理異常

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

例子：

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

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

使用handle可以更靈活：

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

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

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

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

例子：

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

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

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

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

以上是什么是``ploteable future''？的詳細內(nèi)容。更多信息請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！