Java 9 で Flow API を使用してリアクティブ ストリーミングを実装するにはどうすればよいですか?

Flow API は、Java 9 以降のリアクティブ フロー仕様の公式サポートです。これは、Iterator と Observer を組み合わせた パターンです。 Flow API は相互運用仕様であり、RxJava のようなエンドユーザー API ではありません。

フロー API は 4 つの基本インターフェイスで構成されます。

• サブスクライバ : サブスクライバからパブリッシャーへ コールバックへのサブスクライブ。
• パブリッシャー: パブリッシャーは、登録されたサブスクライバーにデータ項目のストリームをパブリッシュします。
• サブスクリプション: パブリッシャーとサブスクライバー間のリンク。
• プロセッサ: プロセッサは、パブリッシャとサブスクライバの間に位置し、あるストリームを別のストリームに変換します。

以下の例では、データ オブジェクトをリクエストし、それを印刷し、別のデータ オブジェクトをリクエストする基本的なサブスクライバを作成します。 Java によって提供されるパブリッシャー実装 (SubmissionPublisher) を使用してセッションを完了できます。

例

import java.util.concurrent.Flow;
import java.util.List;
import java.util.concurrent.SubmissionPublisher;

class MySubscriber&lt;T&gt;implements <strong>Flow.Subscriber&lt;T&gt;</strong> {
   private <strong>Flow.Subscription</strong> subscription;
   <strong>@Override</strong>
   public void <strong>onSubscribe</strong>(Flow.Subscription subscription) {
      this.subscription = subscription;
      this.subscription.request(1);
   }
   <strong>@Override</strong>
   public void <strong>onNext</strong>(T item) {
      System.out.println(item);
      subscription.request(1);
   }
   <strong>@Override</strong>
   public void <strong>onError</strong>(Throwable throwable) {
      throwable.printStackTrace();
   }
   <strong>@Override</strong>
   public void <strong>onComplete</strong>() {
      System.out.println(&quot;Done&quot;);
   }
}

<strong>// main class</strong>
public class FlowTest {
   public static void main(String args[]) {
      <strong>List&lt;String&gt;</strong> items = <strong>List.of</strong>(&quot;1&quot;, &quot;2&quot;, &quot;3&quot;, &quot;4&quot;, &quot;5&quot;, &quot;6&quot;, &quot;7&quot;, &quot;8&quot;, &quot;9&quot;, &quot;10&quot;);
      <strong>SubmissionPublisher&lt;String&gt;</strong> publisher = new SubmissionPublisher&lt;&gt;();
      publisher.<strong>subscribe</strong>(new MySubscriber&lt;&gt;());
      items.forEach(s -&gt; {
         try {
            Thread.sleep(1000);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
         publisher.<strong>submit</strong>(s);
      });
      publisher.close();
   }
}

出力

<strong>1
2
3
4
5
6
7
8
9</strong>
<strong>10
Done</strong>

以上がJava 9 で Flow API を使用してリアクティブ ストリーミングを実装するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。