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


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

      • ProcedureFJTaskRunner

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

      • createAndExecuteTasks

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

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

        public void executeAndCombine​(java.util.concurrent.Executor executor,
                                      ProcedureFactory<BT> procedureFactory,
                                      java.util.List<T> list)
      • join

        private void join()
      • combineTasks

        private void combineTasks()