Java 9 FLow SubmissionPublisher – A Concrete Publisher

java9

12

SubmissionPublisher

1

Concrete Publisher

1

loveprogramming viết ngày 22/04/2021

I. Technologies

• Java 9
• Eclipse with Java 9 Support for Oxygen (4.7)

  II. Overview

  1. SubmissionPublisher

  SubmissionPublisher is an implementation of Java 9 Flow.Publisher that asynchronously issues items to its subscribers until closing.

Depending on usage, we can indicate the Executor for SubmissionPublisher in its constructor methods:

• If we wanna submitting items in separate threads, and can estimate number of subscribers, consider using Executors.newFixedThreadPool(int) and constructor method:

  
  SubmissionPublisher(Executor executor, int maxBufferCapacity);
  // maxBufferCapacity: the maximum capacity for each subscriber's buffer.
  

• Otherwise, just call the default constructor (no input parameter) that will use ForkJoinPool.commonPool().

If a Subscriber has only one action that requests and processes all items, we can consider using consume(Consumer) method (which returns a CompletableFuture object) like this:

publisher.consume((data) -> process(data));

https://grokonez.com/java/java-9/java-9-flow-submissionpublisher-concrete-publisher

Java 9 FLow SubmissionPublisher – A Concrete Publisher