
从 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中文网其它相关文章!
java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号