CompleteFutureは、非同期プログラミングとマルチスレッドタスク処理を簡素化するためにJava 8に導(dǎo)入されたクラスです。 1.將來の手動での完了、チェーンコール、複數(shù)の非同期操作の組み合わせ、統(tǒng)一された例外処理をサポートします。 2。Java 5 Futureと比較して、より強力であり、結(jié)果を手動で設(shè)定し、チェーン操作を設(shè)定し、タスクを組み合わせ、例外を柔軟に処理できます。 3. SupplyAsyncまたはRunaSyncを使用して、非同期タスクを作成し、スレッドプールを指定します。 4.その後、結(jié)果を変換し、消費の結(jié)果を確認(rèn)し、その後の操作を?qū)g行するために承認(rèn)します。 5.シェンポスシリアルの組み合わせタスク、ThenCombine平行マージの結(jié)果。 6.例外的およびハンドルメソッドは例外を処理し、デフォルト値または統(tǒng)一ロジックを提供します。

CompleteFutureは、Java 8で導(dǎo)入されたクラスで、非同期プログラミングとマルチスレッドタスクをより便利に処理します。簡単に言えば、それは完了し、チェーンコールをサポートし、複數(shù)の非同期操作を組み合わせ、例外を処理できる手動の未來です。

未來とは何ですか？

CompleteableFutureについて話す前に、最初にFuture理解する必要があります。これは、非同期計算の結(jié)果を表すためにJava 5に導(dǎo)入されたインターフェイスです。タスクをスレッドプールに送信し、Get a Futureを送信してから、 get()メソッドを使用して結(jié)果を取得できます。

しかし、將來には問題があります。機(jī)能は基本的すぎます。例えば：

• 結(jié)果を手動で設(shè)定することはできません
• チェーン操作はサポートされていません
• 結(jié)果と複數(shù)の先物を組み合わせることは困難です
• 例外処理は十分に柔軟ではありません

CompletableFutureは、これらの問題を解決するように設(shè)計されています。

完了可能な財布を使用して、非同期タスクを?qū)g行します

バックグラウンドで実行される非同期タスクを作成し、メインスレッドは他の操作を?qū)g行し続けることができます。

 completeablefuture <string> future = completablefuture.supplyasync（（） - > {{
    //シミュレーション時間のかかる操作try {
        thread.sleep（1000）;
    } catch（arternedexception e）{
        e.printstacktrace（）;
    }
    「asyncからこんにちは」を返します。
}）;

上記のコードは、スレッドプールでタスクを非同期に実行します。デフォルトはForkJoinPool.commonPool()です。また、獨自のスレッドプールに渡すこともできます。

結(jié)果を待つ必要がある場合は、次のように電話してください。

文字列result = future.get（）; //結(jié)果の準(zhǔn)備ができるまでブロックします

チェーンコール：Then Apply、TheNaccept、Thenrun

CompleteFutureはチェーンコールをサポートし、非同期操作間の接続をより自然にします。

その後、Apply：結(jié)果を変換します

CompleteFuture <Integer> future = completeFuture.supplyasync（（） - > "hello"））
    .thenapply（s-> s.length（））;

これが意味するのは、文字列を非同期に「hello」を返し、長さ5に変えることです。

Theraccept：消費結(jié)果（リターンなし）

 CompleteableFuture <void> future = completablefuture.supplyasync（（） - > "world"））
    .thenaccept（system.out :: println）;

世界を印刷しますが、値は返されません。

thenrun：後続のアクションを?qū)g行する（以前の結(jié)果を気にしない）

 completeablefuture <void> future = completeablefuture.runasync（（） - > system.out.println（ "タスク1"）））
    .thenrun（（） - > system.out.println（ "タスク2"））;

複數(shù)の非同期タスクの組み合わせ：ThencomposeとThencombine

Thencompose：シリアル構(gòu)成

以前のタスクの結(jié)果を次のタスクへの入力として取得するのに適しています。

 completeablefuture <integer> future = completablefuture.supplyasync（（） - > "123"）
    .thencompose（s-> completeablefuture.supplyasync（（） - > integer.parseint（s）））;

ThenCombine：2つのタスクを並行して組み合わせて、結(jié)果をマージする

CompleteFuture <Integer> future1 = completeFuture.supplyasync（（） - > 10）;
completeFuture <integer> future2 = completeFuture.supplyasync（（） - > 20）;

future1.thencombine（future2、（a、b） - > ab）;

このようにして、2つの非同期結(jié)果を一緒に追加できます。

例外の処理：例外的でハンドル

非同期タスクもエラーを引き起こす可能性があり、CompleteFutureは例外を処理する方法を提供します。

例外的に：例外が発生したときにデフォルト値を提供します

CompleteFuture <Integer> future = completeFuture.supplyasync（（） - > {{
    if（true）new runtimeexception（ "oops"）;
    100を返します。
}）。例外的に（ex-> {
    system.out.println（ "エラーが発生しました：" ex.getMessage（））;
    0を返します。 //デフォルト値}）;

ハンドル：例外であるかどうかに関係なく実行され、統(tǒng)一された方法で処理できます

CompleteFuture <Integer> future = completeFuture.supplyasync（（） - > {{
    100を返します。
}）。handle（（result、ex） - > {
    if（ex！= null）{
        System.out.println（ "Exception：" ex.getMessage（））;
        0を返します。
    }
    結(jié)果を返す * 2;
}）;

一般的な方法を要約します

• 非同期タスクを作成する： supplyAsync / runAsync
• 変換結(jié)果： thenApply
• 消費結(jié)果： thenAccept
• フォローアップ操作： thenRun
• シリアルの組み合わせ： thenCompose
• 並列の組み合わせ： thenCombine
• 例外処理： exceptionally / handle

基本的にそれだけです。 CompleteFutureは強力ですが、始めると少し複雑に感じるかもしれません。簡単なタスクから始めて、徐々にチェーンコールと組み合わせ方法をマスターすることをお勧めします。

以上がJavaの完成可能な顧客とは何ですか？の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。