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


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

      • ArrayProcedureFJTaskRunner

        public ArrayProcedureFJTaskRunner​(Combiner<BT> newCombiner,
                                          int newTaskCount)
    • Method Detail

      • createAndExecuteTasks

        private void createAndExecuteTasks​(java.util.concurrent.Executor executor,
                                           ProcedureFactory<BT> procedureFactory,
                                           T[] array)
        Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
      • join

        private void join()
      • executeAndCombine

        public void executeAndCombine​(java.util.concurrent.Executor executor,
                                      ProcedureFactory<BT> procedureFactory,
                                      T[] array)
      • setFailed

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

        private void combineTasks()