在Java 9中，我们如何实现SubmissionPublisher类？

从 Java 9 开始，我们可以通过引入四个核心接口来创建Reactive Streams：Publisher、Subscriber、Subscription、Processor 和一个具体类：实现 Publisher 的 SubmissionPublisher界面。每个界面都扮演着不同的角色，对应于响应式流的原则。我们可以使用 SubmissionPublisher 类的 submit() 方法将提供的项目发布给每个订阅者。

语法

public class SubmissionPublisher extends Object implements Flow.Publisher, AutoCloseable登录后复制

示例

import java.util.concurrent.Flow.Subscriber; import java.util.concurrent.Flow.Subscription; import java.util.concurrent.SubmissionPublisher; class MySubscriber implements Subscriber { private Subscription subscription; private String name; public MySubscriber(String name) { this.name = name; } @Override public void onComplete() { System.out.println(name + ": onComplete"); } @Override public void onError(Throwable t) { System.out.println(name + ": onError"); t.printStackTrace(); } @Override public void onNext(T msg) { System.out.println(name + ": " + msg.toString() + " received in onNext"); subscription.request(1); } @Override public void onSubscribe(Subscription subscription) { System.out.println(name + ": onSubscribe"); this.subscription = subscription; subscription.request(1); } } // Main class public class FlowTest { public static void main(String args[]) { SubmissionPublisher publisher = new SubmissionPublisher(); MySubscriber subscriber = new MySubscriber("Mine"); MySubscriber subscriberYours = new MySubscriber("Yours"); MySubscriber subscriberHis = new MySubscriber("His"); MySubscriber subscriberHers = new MySubscriber("Her"); publisher.subscribe(subscriber); publisher.subscribe(subscriberYours); publisher.subscribe(subscriberHis); publisher.subscribe(subscriberHers); publisher.submit("One"); publisher.submit("Two"); publisher.submit("Three"); publisher.submit("Four"); publisher.submit("Five"); try { Thread.sleep(1000); } catch(InterruptedException e) { e.printStackTrace(); } publisher.close(); } }登录后复制