Class SubmissionPublisher.ConsumerTask<T>

java.lang.Object
java.util.concurrent.ForkJoinTask<Void>
org.glassfish.jersey.internal.jsr166.SubmissionPublisher.ConsumerTask<T>
All Implemented Interfaces:
Serializable, Runnable, CompletableFuture.AsynchronousCompletionTask, Future<Void>
Enclosing class:
SubmissionPublisher<T>

static final class SubmissionPublisher.ConsumerTask<T> extends ForkJoinTask<Void> implements Runnable, CompletableFuture.AsynchronousCompletionTask
A task for consuming buffer items and signals, created and executed whenever they become available. A task consumes as many items/signals as possible before terminating, at which point another task is created when needed. The dual Runnable and ForkJoinTask declaration saves overhead when executed by ForkJoinPools, without impacting other kinds of Executors.