Class ProcedureFJTaskRunner<T,BT extends Procedure<? super T>>
java.lang.Object
org.eclipse.collections.impl.parallel.ProcedureFJTaskRunner<T,BT>
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Throwable
private final CountDownLatch
private final BlockingQueue
<BT> private final Function
<ProcedureFJTask<T, BT>, BT> private ProcedureFJTask<T,
BT>[] private final int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
private void
createAndExecuteTasks
(Executor executor, ProcedureFactory<BT> procedureFactory, List<T> list) void
executeAndCombine
(Executor executor, ProcedureFactory<BT> procedureFactory, List<T> list) private void
join()
void
void
taskCompleted
(ProcedureFJTask<T, BT> task)
-
Field Details
-
procedureFunction
-
procedures
-
error
-
combiner
-
taskCount
private final int taskCount -
outputQueue
-
latch
-
-
Constructor Details
-
ProcedureFJTaskRunner
-
-
Method Details
-
createAndExecuteTasks
private void createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, List<T> list) -
setFailed
-
taskCompleted
-
executeAndCombine
public void executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, List<T> list) -
join
private void join() -
combineTasks
private void combineTasks()
-