Class FJListObjectIntProcedureRunner<T,PT extends ObjectIntProcedure<? super T>>
- java.lang.Object
-
- org.eclipse.collections.impl.forkjoin.FJListObjectIntProcedureRunner<T,PT>
-
- All Implemented Interfaces:
java.io.Serializable
public class FJListObjectIntProcedureRunner<T,PT extends ObjectIntProcedure<? super T>> extends java.lang.Object implements java.io.Serializable
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
FJListObjectIntProcedureRunner.ProcedureExtractor
-
Field Summary
Fields Modifier and Type Field Description private Combiner<PT>
combiner
private java.lang.Throwable
error
private java.util.concurrent.BlockingQueue<PT>
outputQueue
private static long
serialVersionUID
private int
taskCount
-
Constructor Summary
Constructors Constructor Description FJListObjectIntProcedureRunner(Combiner<PT> newCombiner, int taskCount)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private FastList<java.util.concurrent.ForkJoinTask<PT>>
createAndExecuteTasks(java.util.concurrent.ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, java.util.List<T> list)
protected FJListObjectIntProcedureTask<T,PT>
createTask(ObjectIntProcedureFactory<PT> procedureFactory, java.util.List<T> list, int sectionSize, int taskCountMinusOne, int index)
void
executeAndCombine(java.util.concurrent.ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, java.util.List<T> list)
private void
join()
void
setFailed(java.lang.Throwable newError)
void
taskCompleted(java.util.concurrent.ForkJoinTask<PT> task)
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
error
private java.lang.Throwable error
-
combiner
private final Combiner<PT extends ObjectIntProcedure<? super T>> combiner
-
taskCount
private final int taskCount
-
outputQueue
private final java.util.concurrent.BlockingQueue<PT extends ObjectIntProcedure<? super T>> outputQueue
-
-
Method Detail
-
createAndExecuteTasks
private FastList<java.util.concurrent.ForkJoinTask<PT>> createAndExecuteTasks(java.util.concurrent.ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, java.util.List<T> list)
-
createTask
protected FJListObjectIntProcedureTask<T,PT> createTask(ObjectIntProcedureFactory<PT> procedureFactory, java.util.List<T> list, int sectionSize, int taskCountMinusOne, int index)
-
setFailed
public void setFailed(java.lang.Throwable newError)
-
taskCompleted
public void taskCompleted(java.util.concurrent.ForkJoinTask<PT> task)
-
executeAndCombine
public void executeAndCombine(java.util.concurrent.ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, java.util.List<T> list)
-
join
private void join()
-
-