Class BatchIterableProcedureFJTaskRunner<T,​BT extends Procedure<? super T>>


  • public final class BatchIterableProcedureFJTaskRunner<T,​BT extends Procedure<? super T>>
    extends java.lang.Object
    • Constructor Detail

      • BatchIterableProcedureFJTaskRunner

        public BatchIterableProcedureFJTaskRunner​(Combiner<BT> newCombiner,
                                                  int taskCount)
    • Method Detail

      • createAndExecuteTasks

        private void createAndExecuteTasks​(java.util.concurrent.Executor executor,
                                           ProcedureFactory<BT> procedureFactory,
                                           BatchIterable<T> batchIterable)
      • setFailed

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

        private void join()
      • combineTasks

        private void combineTasks()