Class 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.
    • 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
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • getRawResult

        public final java.lang.Void getRawResult()
        Specified by:
        getRawResult in class java.util.concurrent.ForkJoinTask<java.lang.Void>
      • setRawResult

        public final void setRawResult​(java.lang.Void v)
        Specified by:
        setRawResult in class java.util.concurrent.ForkJoinTask<java.lang.Void>
      • exec

        public final boolean exec()
        Specified by:
        exec in class java.util.concurrent.ForkJoinTask<java.lang.Void>
      • run

        public final void run()
        Specified by:
        run in interface java.lang.Runnable