Class FJListProcedureRunner<T,PT extends Procedure<? super T>>
java.lang.Object
org.eclipse.collections.impl.forkjoin.FJListProcedureRunner<T,PT>
- All Implemented Interfaces:
Serializable
public class FJListProcedureRunner<T,PT extends Procedure<? super T>>
extends Object
implements Serializable
- See Also:
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate Throwable
private final BlockingQueue
<PT> private static final long
private final int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate FastList
<ForkJoinTask<PT>> createAndExecuteTasks
(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, List<T> list) protected FJListProcedureTask
<T, PT> createTask
(ProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index) void
executeAndCombine
(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, List<T> list) private void
join()
void
void
taskCompleted
(ForkJoinTask<PT> task)
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
error
-
combiner
-
taskCount
private final int taskCount -
outputQueue
-
-
Constructor Details
-
FJListProcedureRunner
-
-
Method Details
-
createAndExecuteTasks
private FastList<ForkJoinTask<PT>> createAndExecuteTasks(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, List<T> list) -
createTask
protected FJListProcedureTask<T,PT> createTask(ProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index) -
setFailed
-
taskCompleted
-
executeAndCombine
public void executeAndCombine(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, List<T> list) -
join
private void join()
-