Class ArrayProcedureFJTaskRunner<T,BT extends Procedure<? super T>>
java.lang.Object
org.eclipse.collections.impl.parallel.ArrayProcedureFJTaskRunner<T,BT>
-
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
<ArrayProcedureFJTask<T, BT>, BT> private ArrayProcedureFJTask<T,
BT>[] private final int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
private void
createAndExecuteTasks
(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array) Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.void
executeAndCombine
(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array) private void
join()
void
void
taskCompleted
(ArrayProcedureFJTask<T, BT> task)
-
Field Details
-
procedureFunction
-
procedures
-
error
-
latch
-
combiner
-
outputQueue
-
taskCount
private final int taskCount
-
-
Constructor Details
-
ArrayProcedureFJTaskRunner
-
-
Method Details
-
createAndExecuteTasks
private void createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array) Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory. -
taskCompleted
-
join
private void join() -
executeAndCombine
-
setFailed
-
combineTasks
private void combineTasks()
-