Java 9 の Reactive Streams のコア インターフェイスは何ですか?

Java 9 では、相互運用可能な Publish- をサポートするために、 java.util.concurrent.Flow パッケージの下に 応答フロー が導入されています。購読するフレームワーク。非同期境界を越えた非同期データ ストリームを処理し (別のスレッドまたはスレッド プールに要素を渡す)、受信側はいかなる量のデータもバッファリングする必要がないため、バッファ オーバーフローは発生しません。

Flow API には、相互に関連する 4 つのコア インターフェイス (Publisher、Subscriber、Subscribe、processor##) が含まれています。 ＃。 構文

<strong>@FunctionalInterface
</strong>public static interface <strong>Publisher<T></strong> {
   public void <strong>subscribe</strong>(<strong>Subscriber</strong><? super T><!--? super T--> subscriber)
}
public static interface <strong>Subscriber<T></strong> {
   public void <strong>onSubscribe</strong>(Subscription subscription);
   public void <strong>onNext</strong>(T item);
   public void <strong>onError</strong>(Throwable throwable);
   public void <strong>onComplete</strong>();
}
public static interface <strong>Subscription </strong>{
   public void <strong>request</strong>(long n);
   public void <strong>cancel</strong>();
}
public static interface <strong>Processor<T, R> </strong>extends <strong>Subscriber<T></strong>, <strong>Publisher<R></strong> {
}

これらの 4 つのインターフェイス:

Flow.Publisher、Flow.Processor、Flow.Subscriber、# ＃＃ 流れ。リアクティブストリームの仕様に関連するサブスクリプション。 Publisher インターフェイスには subscribe() メソッドがあり、subscription には cancel() メソッドと request() メソッドがあります。 ##Subscribers には、onSubscribe()、onNext()、onError()、および >onComplete() メソッドがあります。 Processorインターフェイスは、Flowのすべてのメソッドを実装します。 Publisher および Flow.Subscriber インターフェイス。

以上がJava 9 の Reactive Streams のコア インターフェイスは何ですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。