Class SubmissionPublisher.ConsumerTask<T>
- java.lang.Object
-
- java.util.concurrent.ForkJoinTask<java.lang.Void>
-
- org.glassfish.jersey.internal.jsr166.SubmissionPublisher.ConsumerTask<T>
-
- All Implemented Interfaces:
java.io.Serializable
,java.lang.Runnable
,java.util.concurrent.CompletableFuture.AsynchronousCompletionTask
,java.util.concurrent.Future<java.lang.Void>
- Enclosing class:
- SubmissionPublisher<T>
static final class SubmissionPublisher.ConsumerTask<T> extends java.util.concurrent.ForkJoinTask<java.lang.Void> implements java.lang.Runnable, java.util.concurrent.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.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) SubmissionPublisher.BufferedSubscription<T>
consumer
-
Constructor Summary
Constructors Constructor Description ConsumerTask(SubmissionPublisher.BufferedSubscription<T> consumer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
exec()
java.lang.Void
getRawResult()
void
run()
void
setRawResult(java.lang.Void v)
-
Methods inherited from class java.util.concurrent.ForkJoinTask
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, 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, reinitialize, setForkJoinTaskTag, tryUnfork
-
-
-
-
Field Detail
-
consumer
final SubmissionPublisher.BufferedSubscription<T> consumer
-
-
Constructor Detail
-
ConsumerTask
ConsumerTask(SubmissionPublisher.BufferedSubscription<T> consumer)
-
-
Method Detail
-
getRawResult
public final java.lang.Void getRawResult()
- Specified by:
getRawResult
in classjava.util.concurrent.ForkJoinTask<java.lang.Void>
-
setRawResult
public final void setRawResult(java.lang.Void v)
- Specified by:
setRawResult
in classjava.util.concurrent.ForkJoinTask<java.lang.Void>
-
exec
public final boolean exec()
- Specified by:
exec
in classjava.util.concurrent.ForkJoinTask<java.lang.Void>
-
run
public final void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
-