從Java 9 開始,我們可以透過引入四個核心介面來建立Reactive Streams:Publisher 、Subscriber、Subscription、Processor 和一個具體類別:實作Publisher 的SubmissionPublisher介面。每個介面都扮演不同的角色,對應於響應式流的原則。我們可以使用 SubmissionPublisher 類別的 submit() 方法將提供的項目發佈給每個訂閱者。
語法
<strong>public class SubmissionPublisher<T> extends Object implements Flow.Publisher<T>, AutoCloseable</strong>
在下面的範例中,我們可以實作SubmissionPublisher 類別
範例
import java.util.concurrent.Flow.Subscriber; import java.util.concurrent.Flow.Subscription; import java.util.concurrent.SubmissionPublisher; class MySubscriber<T> implements <strong>Subscriber<T></strong> { private <strong>Subscription </strong>subscription; private String name; public MySubscriber(String name) { this.name = name; } <strong>@Override</strong> public void <strong>onComplete()</strong> { System.out.println(name + ": onComplete"); } <strong>@Override</strong> public void <strong>onError</strong>(Throwable t) { System.out.println(name + ": onError"); t.printStackTrace(); } <strong> @Override</strong> public void <strong>onNext</strong>(T msg) { System.out.println(name + ": " + msg.toString() + " received in onNext"); subscription.<strong>request</strong>(1); } <strong>@Override</strong> public void <strong>onSubscribe</strong>(Subscription subscription) { System.out.println(name + ": onSubscribe"); this.subscription = subscription; subscription.<strong>request</strong>(1); } } <strong>// Main class</strong> public class FlowTest { public static void main(String args[]) { <strong>SubmissionPublisher<String></strong> publisher = new <strong>SubmissionPublisher</strong><>(); MySubscriber<String> subscriber = new MySubscriber<>("Mine"); MySubscriber<String> subscriberYours = new MySubscriber<>("Yours"); MySubscriber<String> subscriberHis = new MySubscriber<>("His"); MySubscriber<String> subscriberHers = new MySubscriber<>("Her"); publisher.<strong>subscribe</strong>(subscriber); publisher.<strong>subscribe</strong>(subscriberYours); publisher.<strong>subscribe</strong>(subscriberHis); publisher.<strong>subscribe</strong>(subscriberHers); publisher.<strong>submit</strong>("One"); publisher.<strong>submit</strong>("Two"); publisher.<strong>submit</strong>("Three"); publisher.<strong>submit</strong>("Four"); publisher.<strong>submit</strong>("Five"); try { Thread.sleep(1000); } catch(InterruptedException e) { e.printStackTrace(); } publisher.close(); } }
輸出
<strong>Yours: onSubscribe His: onSubscribe Mine: onSubscribe His: One received in onNext Yours: One received in onNext Mine: One received in onNext Yours: Two received in onNext His: Two received in onNext Yours: Three received in onNext Mine: Two received in onNext Yours: Four received in onNext His: Three received in onNext Yours: Five received in onNext Mine: Three received in onNext Her: onSubscribe His: Four received in onNext Her: One received in onNext Mine: Four received in onNext Her: Two received in onNext His: Five received in onNext Her: Three received in onNext Mine: Five received in onNext Her: Four received in onNext Her: Five received in onNext Yours: onComplete His: onComplete Mine: onComplete Her: onComplete</strong>
以上是在Java 9中,我們如何實作SubmissionPublisher類別?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

本文討論了使用Maven和Gradle進行Java項目管理,構建自動化和依賴性解決方案,以比較其方法和優化策略。

本文使用Maven和Gradle之類的工具討論了具有適當的版本控制和依賴關係管理的自定義Java庫(JAR文件)的創建和使用。

本文討論了使用咖啡因和Guava緩存在Java中實施多層緩存以提高應用程序性能。它涵蓋設置,集成和績效優勢,以及配置和驅逐政策管理最佳PRA

本文討論了使用JPA進行對象相關映射,並具有高級功能,例如緩存和懶惰加載。它涵蓋了設置,實體映射和優化性能的最佳實踐,同時突出潛在的陷阱。[159個字符]

Java的類上載涉及使用帶有引導,擴展程序和應用程序類負載器的分層系統加載,鏈接和初始化類。父代授權模型確保首先加載核心類別,從而影響自定義類LOA


熱AI工具

Undresser.AI Undress
人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool
免費脫衣圖片

Clothoff.io
AI脫衣器

AI Hentai Generator
免費產生 AI 無盡。

熱門文章

熱工具

MinGW - Minimalist GNU for Windows
這個專案正在遷移到osdn.net/projects/mingw的過程中,你可以繼續在那裡關注我們。 MinGW:GNU編譯器集合(GCC)的本機Windows移植版本,可自由分發的導入函式庫和用於建置本機Windows應用程式的頭檔;包括對MSVC執行時間的擴展,以支援C99功能。 MinGW的所有軟體都可以在64位元Windows平台上運作。

SublimeText3 Linux新版
SublimeText3 Linux最新版

DVWA
Damn Vulnerable Web App (DVWA) 是一個PHP/MySQL的Web應用程序,非常容易受到攻擊。它的主要目標是成為安全專業人員在合法環境中測試自己的技能和工具的輔助工具,幫助Web開發人員更好地理解保護網路應用程式的過程,並幫助教師/學生在課堂環境中教授/學習Web應用程式安全性。 DVWA的目標是透過簡單直接的介面練習一些最常見的Web漏洞,難度各不相同。請注意,該軟體中

Atom編輯器mac版下載
最受歡迎的的開源編輯器

Safe Exam Browser
Safe Exam Browser是一個安全的瀏覽器環境,安全地進行線上考試。該軟體將任何電腦變成一個安全的工作站。它控制對任何實用工具的訪問,並防止學生使用未經授權的資源。