Class ObjectIntProcedureFJTaskRunner<T,BT extends ObjectIntProcedure<? super T>>
java.lang.Object
org.eclipse.collections.impl.parallel.ObjectIntProcedureFJTaskRunner<T,BT>
public final class ObjectIntProcedureFJTaskRunner<T,BT extends ObjectIntProcedure<? super T>>
extends Object
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate final class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Throwable
private final CountDownLatch
private final BlockingQueue
<BT> private final Function
<ObjectIntProcedureFJTask<T, BT>, BT> private ObjectIntProcedureFJTask<T,
BT>[] private final int
-
Constructor Summary
ConstructorsConstructorDescriptionObjectIntProcedureFJTaskRunner
(Combiner<BT> newCombiner, int taskCount) ObjectIntProcedureFJTaskRunner
(Combiner<BT> newCombiner, int taskCount, BlockingQueue<BT> queue, CountDownLatch latch) -
Method Summary
Modifier and TypeMethodDescriptionprivate static <BT> CountDownLatch
buildCountDownLatch
(Combiner<BT> newCombiner, int taskCount) private static <BT> ArrayBlockingQueue
<BT> buildQueue
(Combiner<BT> newCombiner, int taskCount) private void
private void
createAndExecuteTasks
(Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, List<T> list) void
executeAndCombine
(Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, List<T> list) private void
join()
void
void
taskCompleted
(ObjectIntProcedureFJTask<T, BT> task)
-
Field Details
-
procedureFunction
private final Function<ObjectIntProcedureFJTask<T,BT extends ObjectIntProcedure<? super T>>, procedureFunctionBT extends ObjectIntProcedure<? super T>> -
procedures
-
error
-
combiner
-
taskCount
private final int taskCount -
outputQueue
-
latch
-
-
Constructor Details
-
ObjectIntProcedureFJTaskRunner
-
ObjectIntProcedureFJTaskRunner
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount, BlockingQueue<BT> queue, CountDownLatch latch)
-
-
Method Details
-
buildCountDownLatch
-
buildQueue
-
createAndExecuteTasks
private void createAndExecuteTasks(Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, List<T> list) -
setFailed
-
taskCompleted
-
executeAndCombine
public void executeAndCombine(Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, List<T> list) -
join
private void join() -
combineTasks
private void combineTasks()
-