Javaは、完了可能な財政、レスポンシブストリーム（プロジェクトリアクターなど）、およびJava 19の仮想スレッドの使用など、非同期プログラミングをサポートします。 2。プロジェクトリアクターは、逆圧力メカニズムとリッチ演算子を備えた応答性プログラミングを?qū)g裝するためのモノとフラックスタイプを提供します。 3.仮想スレッドは、同時性コストを削減し、I/O集約型タスクに適しており、従來のプラットフォームスレッドよりも軽量で拡張が容易です。各アプローチには適用可能なシナリオがあり、適切なツールをニーズに応じて選択する必要があり、混合モデルはシンプルさを維持するために避ける必要があります。

Javaは、特にCompletableFuture 、Reactive Streams、および最近ではJava 19の仮想スレッドなどの機能の進化に伴い、非同期プログラミングをサポートする上で長い道のりを歩んできました。 Webサービスやリアルタイムのデータ処理など、高い並行性を必要とするアプリケーションに取り組んでいる場合、非同期タスクを効率的に管理する方法を理解することが重要です。

Cleaner AsyncコードのためにCompletableFutureを使用します

CompletableFuture前に（Java 8で導入）、非同期操作の管理は、しばしばネストされたコールバックに対処するか、スレッド調(diào)整を手動で処理することを意味します。今、それははるかにスムーズです。

CompletableFutureを使用すると、 .thenApply() 、. .thenAccept() 、および.exceptionally()などの方法を使用して非同期操作をチェーンできます。これにより、コードが読みやすくなるだけでなく、デバッグとメンテナンスも簡単になります。

例えば：

 completeablefuture <string> future = completablefuture.supplyasync（（） - > {{
    //長期にわたるタスクをシミュレートします
    「結(jié)果」を返します。
}）;

future.thenapply（result-> result "Processed"）
      .thenaccept（system.out :: println）;

留意すべきいくつかのこと：

• 必要でない限り、呼び出しをブロックしないでください。 .thenApply()または.thenCompose()を使用して、流れを継続します。
• .exceptionally()または.handle()を使用して例外を優(yōu)雅に処理するため、Asyncパイプラインは靜かに失敗しません。
• 一般的なフォークに結(jié)合するプールに依存する代わりに、スレッドプールをさらに制御したい場合は、カスタムエグゼキューターを使用してください。

プロジェクトリアクターとのリアクティブストリームを活用します

イベント駆動型アーキテクチャやストリーミングAPIなど、データのストリームを扱うシステムを構(gòu)築する場合、反応性プログラミングは自然に適合します。 Project Reactorなどのライブラリは、0..1（ Mono ）または0..N（ Flux ）アイテムの非同期シーケンスを表すMonoおよびFluxタイプを提供します。

ユーザーデータを非同期に取得する簡単な例は次のとおりです。

 mono <user> usermono = userservice.getuserbyid（123）;
usermono.subscribe（user-> system.out.println（ "got user：" user.getname（））;

リアクティブなストリームは、生産者が消費者よりも速いときにシステムを圧倒するのを防ぐのに役立ちます。また、 map 、 flatMap 、 filter 、 zipなどの演算子により、複雑な非同期ロジックが驚くほどきれいになります。

いくつかのヒント：

• 結(jié)果を理解せずに、ブロッキングスタイルと非ブロッキングスタイルを混ぜないでください。
• .subscribeOn()と.publishOn()を使用してスケジューラを指定することにより、変換がどこで発生するかについて注意してください。
• リアクティブパイプライン內(nèi)のI/OバウンドタスクをブロックするためにSchedulers.boundedElastic()を使用します。

仮想スレッドの探索（Java 19）

JavaのAsync機能への最近の最大の追加の1つは、Java 19から始まるProject Loomの一部として導入された仮想スレッドです。

プラットフォームスレッド（従來のOSバックスレッド）とは異なり、仮想スレッドは軽量で、JVMによって管理されています。これは、通常のオーバーヘッドなしで何百萬ものそれらを生成できることを意味します。

試してみるには：

 executorservice executor = executors.newvirtualthreadpertaskexecutor（）;

executor.submit（（） - > {
    //ここで長期にわたるタスクまたはブロッキングタスク
    nullを返します。
}）;

これは、HTTPクライアント、データベース呼び出し、またはメッセージブローカーなどのI/Oヘビーワークロードに特に便利です。

キーポイント：

• 仮想スレッドは魔法ではありません。リソースが必要であり、プラットフォームスレッドよりも少ないリソースが必要です。
• それ以外の場合は、通常のスレッドを縛るブロッキングスタイルのコードで使用する場合に最適に機能します。
• 既存の非同期ライブラリは、すぐにフードの下でこれを利用するために進化する可能性があります。

現(xiàn)代のJavaの非同期プログラミングは、ユースケースに応じていくつかの堅実なパスを提供します。 CompletableFutureに固執(zhí)している場合でも、完全に反応している場合でも、仮想スレッドを?qū)g験している場合でも、各アプローチはテーブルに獨自の強みをもたらします。トリックは、どのツールに到達するかを知ることと、本當に柔軟性が必要な場合を除き、ミキシングモデルを回避することです。

それは基本的にそれです。

以上が現(xiàn)代のジャワの非同期プログラミング技術(shù)の詳細內(nèi)容です。詳細については、PHP 中國語 Web サイトの他の関連記事を參照してください。