プロジェクトの織機(jī)は、多くの場合、仮想スレッドを介してブロッキング操作を安価にすることにより、リアクティブプログラミングの必要性を減らし、シンプルで同期スタイルのコードを効率的に拡張できるようにします。 2。リアクティブプログラミングは、バックプレッシャーの取り扱い、大量または無限のデータストリーム、および複雑な非同期組成に関連しています。 3.仮想スレッドは、読み取り可能なコードでI/Oバウンドのブロックシナリオで優(yōu)れていますが、微細(xì)な制御、ストリーム処理、および織機(jī)のない環(huán)境には反応性パターンが依然として好まれます。 4. 2つは、仮想スレッドで実行されるリアクティブパイプラインまたは仮想スレッドバックスケジューラーを使用して、シンプルさとコントロールを組み合わせて共存できます。 5. Javaの並行性の將來は、高度な機(jī)能が必要な場合にのみリアクティブアプローチを使用して、デフォルトで単純なブロックコードを支持します。つまり、リアクターやWebfluxなどのリアクティブライブラリは廃止されませんが、賢明に使用する必要があります。

Javaのリアクティブプログラミングは、従來、プロジェクトリアクターやRXJAVAなどのライブラリに依存して、特にWebサーバーやイベント駆動型のシステムなどの高電流シナリオでは、非同期の非ブロッキング操作を処理していました。ただし、Java 21にプロジェクト織機(jī)と仮想スレッドが到著すると、同時プログラミングの風(fēng)景が劇的に変化しています。これは重要な疑問を提起します：プロジェクト織機(jī)はJavaのリアクティブプログラミングにどのように影響しますか？

短い答え：仮想スレッドは、多くの一般的なユースケースでのリアクティブプログラミングの必要性を減らしますが、特にバックプレッシャー、複雑なデータストリーム、または機(jī)能構(gòu)成を扱う場合、反応性パターンには依然としてその場所があります。

これを分解しましょう。

1.リアクティブプログラミングはどのような問題を解決しましたか？

織機(jī)の前に、従來のブロッキングI/O（jdbc、 Thread.sleep() 、またはblocking httpコール）で數(shù)千の同時リクエストを処理するのは高価でした。各スレッドは重要なメモリ（デフォルトでは1MBスタック）を消費し、OSにはスレッドカウントに制限がありました。

そのため、 ReactorやWebFluxなどのリアクティブなフレームワークが登場しました。

• 非ブロッキングI/Oおよびイベントループ（node.jsなど）を使用します。
• 多くのタスクで少數(shù)のスレッドを共有します。
• map 、 filter 、 flatMapなどの演算子を使用したストリームとしてデータを処理します。
• サポートバックプレッシャー- 消費者はデータフローのレートを制御できます。

このモデルはうまく機(jī)能しましたが、複雑になりました：

• 急な學(xué)習(xí)曲線。
• より硬いデバッグ（スタックトレースが斷片化されます）。
• ブロッキングAPIによる相互運用性が限られています。

2。プロジェクト織機(jī)がゲームをどのように変更するか

Project Loomでは、OSではなくJVMによって管理されるライトウェイトスレッド - 仮想スレッドを?qū)毪筏蓼埂?/p>

主な利點：

• 數(shù)百萬の仮想スレッドは効率的に実行できます。
• 各仮想スレッドは、はるかに少ないメモリ（?何百バイト）を使用します。
• 彼らは安くブロックするように設(shè)計されています。はい、ブロックは大丈夫です。

例：

 executorservice executor = executors.newvirtualthreadpertaskexecutor（）;

intstream.range（0、10_000）.foreach（i-> {{
    executor.submit（（） - > {
        thread.sleep（duration.ofseconds（1））;
        System.out.println（ "done：" i）;
        nullを返します。
    }）;
}）;

これにより、システムを殺さずに眠る（ブロック）10,000個の仮想スレッドが生成されます。プラットフォームスレッドを使用すると、これは失敗またはcraいます。

したがって、ブロッキングを避けるために複雑なリアクティブチェーンを作成する代わりに、スケーリングするシンプルで同期して見えるコードを作成できます。

3。これにより、リアクティブなプログラミングが時代遅れになりますか？

完全ではありません。これが各アプローチが輝くところです：

mirty仮想スレッドを使用して：

• I/Oバインド作業(yè)を行っています（例、HTTP呼び出し、ファイル操作）。
• シンプルで読み取り可能なコードが必要です。
• 逆圧力やストリーム処理は必要ありません。
• APIのブロック（従來のJDBCなど）と統(tǒng)合しています。

 void handlerequest（）{
    var user = db.loduser（）; //ブロック
    var config = service.getConfig（）; // httpのブロック
    emailservice.send（user、config）;
}

仮想スレッドごとのこれらのいずれかを?qū)g行します。 Mono 、 Flux 、コールバックヘルは必要ありません。

?リアクティブプログラミングを維持します。

• バックプレッシャーが必要です（例えば、高速生産者、遅い消費者）。
• 無限または大量のデータストリームを処理しています。
• スケジューリングとスレッドを細(xì)かく制御する必要があります。
• あなたは織機(jī)（古いJavaバージョン）を使用できない環(huán)境にいます。
• リアクティブエコシステム（例えば、Spring WebFlux、R2DBC）に依存しています。

Reactiveは、非同期操作の構(gòu)成と極端な負(fù)荷の下でのリソース使用の管理に依然として優(yōu)れています。

4。彼らは一緒に働くことができますか？

はい - 時にはそれが最良のアプローチです。

仮想スレッド內(nèi)でリアクティブパイプラインを?qū)g行するか、リアクティブタスクの実行ターゲットとして仮想スレッドを使用できます。

例えば：

 Mono.FromCallable（（） - > velyExpensiveBlockingOperation（））
    .subscribeon（Reactor.core.scheduler.schedulers.fromexecutor（
        executors.newvirtualthreadpertaskexecutor（）
    ））;

これで、リアクティブストリームは、仮想スレッドを介した安価なブロッキングの恩恵を受けます。

または、スプリングブート6で仮想スレッドを使用したプロジェクトリアクターを使用します。

 @bean
public Scheduler virtualthreadscheduler（）{
    Return Schedulers.Fromexecutor（executors.NewVirtualThreadPertasKexecutor（））;
}

それから：

 mono.just（ "hello"）
    .publishon（virtualthreadscheduler（））
    .map（this :: blockingTransform）
    。購読する（）;

このハイブリッドモデルは、両方の世界で最高の世界を提供します。Loomの並行性効率を備えたリアクティブストリーム制御。

結(jié)論

• Project Loomはリラクティブプログラミングを殺しません。その役割を再定義します。
• ほとんどの従來のサーバーアプリケーションでは、仮想スレッドが単純なブロッキングコードをスケーラブルにし、反応的な複雑さの必要性を減らします。
• リアクティブプログラミングは、高度なストリーム処理、バックプレッシャー、およびリアクティブシステムとの統(tǒng)合に依然として価値があります。
• 將來は「必要に応じてリアクティブで、デフォルトではシンプル」になる可能性があります。

それで、あなたは原子爐またはWebFluxの使用をやめるべきですか？いいえ - ただし、スレッドの疲労を避けるためだけに使用している場合は再考してください。織機(jī)では、その問題はほぼ解決されます。

基本的に：最初に簡単なコードを書きます。そのユニークな力が必要な場合にのみ、リアクティブにリーチします。

以上がプロジェクト織機(jī)と仮想スレッドを使用したJavaのリアクティブプログラミングの詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。