Class FJBatchIterableProcedureRunner<T,​PT extends Procedure<? super T>>

  • All Implemented Interfaces:
    java.io.Serializable

    public class FJBatchIterableProcedureRunner<T,​PT extends Procedure<? super T>>
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Field Detail

      • error

        private java.lang.Throwable error
      • taskCount

        private final int taskCount
      • outputQueue

        private final java.util.concurrent.BlockingQueue<PT extends Procedure<? super T>> outputQueue
    • Constructor Detail

      • FJBatchIterableProcedureRunner

        public FJBatchIterableProcedureRunner​(Combiner<PT> newCombiner,
                                              int taskCount)
    • Method Detail

      • createAndExecuteTasks

        private FastList<java.util.concurrent.ForkJoinTask<PT>> createAndExecuteTasks​(java.util.concurrent.ForkJoinPool executor,
                                                                                      ProcedureFactory<PT> procedureFactory,
                                                                                      BatchIterable<T> iterable)
      • setFailed

        public void setFailed​(java.lang.Throwable newError)
      • taskCompleted

        public void taskCompleted​(java.util.concurrent.ForkJoinTask<PT> task)
      • executeAndCombine

        public void executeAndCombine​(java.util.concurrent.ForkJoinPool executor,
                                      ProcedureFactory<PT> procedureFactory,
                                      BatchIterable<T> list)
      • join

        private void join()