JavaのCompletableFutureは、従來の將來のインターフェイスよりも柔軟性が高い非ブロッキングコードを有効にすることにより、非同期プログラミングを簡素化します。 1.完全な（）、2。runasync（）またはsuppelyasync（）、3を介した非yync実行をサポートするタスクを手動で完了させることができます。値）とハンドル（カスタムエラー/結(jié)果処理）、および6。スレッド制御、非同期ワークフローの並列性と読みやすさを高める方法の非同期バージョンを提供します。

CompletableFutureは、 java.util.concurrentパッケージの一部としてJava 8に導入されたJavaのクラスです。これは、古いFutureインターフェイスよりも、先物（非同期計算の結(jié)果）をよりきれいかつ柔軟に処理する非ブロッキングコードを作成できるようにすることで、非同期プログラミングを容易にするように設計されています。

CompletableFutureの背後にある主なアイデアは、例外の取り扱い、複數(shù)の先物の組み合わせ、次のステップを?qū)g行するスレッドを指定するなど、タスクがどのように連鎖され、組み合わされているかをより制御できることです。

基本的な使用：先物の作成と完了

いくつかの方法でCompletableFuture顧客を作成できます。

• complete()を使用して手動で完了します
• runAsync()やsupplyAsync()などの方法を使用して非同期タスクを?qū)g行します

例えば：

 completeablefuture <string> future = completablefuture.supplyasync（（） - > {{
    //長期にわたるタスクをシミュレートします
    試す {
        thread.sleep（1000）;
    } catch（arternedexception e）{}
    「こんにちは」を返します。
}）;

future.thenaccept（result-> system.out.println（ "result：" result））;

これにより、1秒後に「Hello」を返す背景タスクが設定され、完了したら印刷します。

未來を手動で完了したい場合（たとえば、テストやカスタムロジックなど）、次のことができます。

 completeablefuture <integer> manualfuture = new completablefuture <>（）;
ManualFuture.comPlete（42）;
ManicalFuture.thenaccept（system.out :: println）; //印刷42

thenApply 、 thenAccept 、およびthenRunで操作をチェーンします

CompletableFuture財政の大きな利點の1つは、スレッドをブロックせずに操作をチェーンする機能です。

各メソッドの仕組みは次のとおりです。

• thenApply結(jié)果を変換します
• thenAccept結(jié)果を消費しますが、何も返さない
• thenRun 、結(jié)果を無視して、完了後にいくつかのコードを?qū)g行します

例：

 completeablefuture <integer> future = completablefuture.supplyasync（（） - > "apple"）
    .thenapply（s-> s.length（））//「Apple」を5に変えます
    .thenapply（len-> len * 2）; // 5は10になります

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

これらの操作は通常、別のエグゼキューターを指定しない限り、以前の將來を完了したのと同じスレッドで実行されます。

先物とthenComposeとthenCombineを組み合わせる

複數(shù)の非同期ステップで作業(yè)する場合、2つの重要な方法は次のとおりです。

• thenCompose - 別の未來を返す未來がある場合にこれを使用してください
• thenCombine - 2つの獨立した先物の結(jié)果を組み合わせるときにこれを使用してください

例えば：

 completeablefuture <integer> future1 = completablefuture.supplyasync（（） - > 10）;
completeablefuture <integer> future2 = completablefuture.supplyasync（（） - > 20）;

//両方の結(jié)果を結(jié)合します
future1.thencombine（future2、（a、b） - > ab）
       .thenaccept（system.out :: println）; // 30を印刷します

そして、あなたが未來の中で未來を返しているなら：

 CompletableFuture <Integer> composed = completablefuture.supplyasync（（） - > 5）
    .thencompose（val-> completeablefuture.supplyasync（（） - > val * 2））;

composed.thenaccept（system.out :: println）; //印刷10

exceptionallyにhandleでエラーを処理します

物事は常にスムーズに進むとは限りません。以下を使用して例外を処理できます。

• exceptionally - エラーが発生した場合、フォールバック値を提供します
• handle - 結(jié)果と例外の両方を検査し、何を返すかを選択できます

例：

 completeablefuture <integer> faultyfuture = completeablefuture.supplyasync（（） - > {{
    （true）new runtimeexception（ "oops！"）を投げるif（true）;
    100を返します。
}）;

faultyfuture
    .exceptally（ex-> {
        system.out.println（ "エラーが発生しました：" ex.getMessage（））;
        0を返します。 //フォールバック値
    }）
    .thenaccept（system.out :: println）; //印刷0

handleを使用すると、柔軟性が高まります。

 completeablefuture <integer> handled = faultyfuture.handle（（result、ex） - > {
    if（ex！= null）{
        System.out.println（ "処理エラー：" ex.getMessage（））;
        返品1; // デフォルト
    }
    返品結(jié)果;
}）;

スレッドをより適切に制御するためのAsyncバージョン

ほとんどの方法には、次の操作に使用するスレッドプールを指定できる非同期バージョン（ thenApplyAsync 、 thenAcceptAsyncなど）が付屬しています。

これは、元のスレッドのブロックを避けたり、作業(yè)を並行したりしたい場合に役立ちます。

例：

 completeablefuture <integer> future = completablefuture.supplyasync（（） - > 10）
    .thenapplyasync（val-> val * 2、executors.newfixedthreadpool（2））;

これにより、乗算が個別のスレッドプールで行われます。

したがって、基本的に、 CompletableFuture 、Javaできれいで読みやすく、効率的な非同期コードを書くのに役立ちます。コールバック地獄で立ち往生することなく、非同期タスクを簡単にチェーン、組み合わせ、管理するためのツールを提供することにより、古いFutureインターフェイスの上に構(gòu)築されます。

それがその核心です。パターンに慣れたら、それほど複雑ではありません。

以上が`completablefuture」とは何ですか？の詳細內(nèi)容です。詳細については、PHP 中國語 Web サイトの他の関連記事を參照してください。