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.
-
Nested Class Summary
Nested classes/interfaces inherited from interface java.util.concurrent.Future
Future.State
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final SubmissionPublisher.BufferedSubscription
<T> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal boolean
exec()
final Void
final void
run()
final void
setRawResult
(Void v) Methods inherited from class java.util.concurrent.ForkJoinTask
adapt, adapt, adapt, adaptInterruptible, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, exceptionNow, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, quietlyJoin, quietlyJoinUninterruptibly, reinitialize, resultNow, setForkJoinTaskTag, state, tryUnfork
-
Field Details
-
consumer
-
-
Constructor Details
-
ConsumerTask
ConsumerTask(SubmissionPublisher.BufferedSubscription<T> consumer)
-
-
Method Details
-
getRawResult
- Specified by:
getRawResult
in classForkJoinTask<Void>
-
setRawResult
- Specified by:
setRawResult
in classForkJoinTask<Void>
-
exec
public final boolean exec()- Specified by:
exec
in classForkJoinTask<Void>
-
run
public final void run()
-