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

  • All Implemented Interfaces:
    java.io.Serializable

    public class FJListProcedureRunner<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

      • FJListProcedureRunner

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

      • createAndExecuteTasks

        private FastList<java.util.concurrent.ForkJoinTask<PT>> createAndExecuteTasks​(java.util.concurrent.ForkJoinPool executor,
                                                                                      ProcedureFactory<PT> procedureFactory,
                                                                                      java.util.List<T> list)
      • 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,
                                      java.util.List<T> list)
      • join

        private void join()