Class ObjectIntProcedureFJTaskRunner<T,​BT extends ObjectIntProcedure<? super T>>


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

      • ObjectIntProcedureFJTaskRunner

        public ObjectIntProcedureFJTaskRunner​(Combiner<BT> newCombiner,
                                              int taskCount)
      • ObjectIntProcedureFJTaskRunner

        ObjectIntProcedureFJTaskRunner​(Combiner<BT> newCombiner,
                                       int taskCount,
                                       java.util.concurrent.BlockingQueue<BT> queue,
                                       java.util.concurrent.CountDownLatch latch)
    • Method Detail

      • buildCountDownLatch

        private static <BT> java.util.concurrent.CountDownLatch buildCountDownLatch​(Combiner<BT> newCombiner,
                                                                                    int taskCount)
      • buildQueue

        private static <BT> java.util.concurrent.ArrayBlockingQueue<BT> buildQueue​(Combiner<BT> newCombiner,
                                                                                   int taskCount)
      • createAndExecuteTasks

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

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

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

        private void join()
      • combineTasks

        private void combineTasks()