Java 9에서 SubmissionPublisher 클래스를 어떻게 구현합니까?

Java 9부터 4개의 핵심 인터페이스인 Publisher, Subscriber, Subscription, Processor과 구체적인 클래스인 Implementing을 도입하여 Reactive Streams을 생성할 수 있습니다. SubmissionPublisherPublisher의 인터페이스. 각 인터페이스는 반응성흐름 원칙에 따라 서로 다른 역할을 수행합니다. SubmissionPublisher 클래스의 submit() 메소드를 사용하여 각 구독자에게 제공된 항목을 게시할 수 있습니다.

Syntax

<strong>public class SubmissionPublisher<T> extends Object implements Flow.Publisher<T>, AutoCloseable</strong>

다음 예에서는 SubmissionPublisher Class

Example

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();
   }
}

Output

<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 중국어 웹사이트의 기타 관련 기사를 참조하세요!