Class FJListObjectIntProcedureRunner<T,PT extends ObjectIntProcedure<? super T>>
java.lang.Object
org.eclipse.collections.impl.forkjoin.FJListObjectIntProcedureRunner<T,PT>
- All Implemented Interfaces:
Serializable
public class FJListObjectIntProcedureRunner<T,PT extends ObjectIntProcedure<? super T>>
extends Object
implements Serializable
- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate final class
-
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, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list) protected FJListObjectIntProcedureTask
<T, PT> createTask
(ObjectIntProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index) void
executeAndCombine
(ForkJoinPool executor, ObjectIntProcedureFactory<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
-
FJListObjectIntProcedureRunner
-
-
Method Details
-
createAndExecuteTasks
private FastList<ForkJoinTask<PT>> createAndExecuteTasks(ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list) -
createTask
protected FJListObjectIntProcedureTask<T,PT> createTask(ObjectIntProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index) -
setFailed
-
taskCompleted
-
executeAndCombine
public void executeAndCombine(ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list) -
join
private void join()
-