Class FJBatchIterableProcedureRunner<T,PT extends Procedure<? super T>>
- java.lang.Object
-
- org.eclipse.collections.impl.forkjoin.FJBatchIterableProcedureRunner<T,PT>
-
- All Implemented Interfaces:
java.io.Serializable
public class FJBatchIterableProcedureRunner<T,PT extends Procedure<? 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
FJBatchIterableProcedureRunner.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 FJBatchIterableProcedureRunner(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, ProcedureFactory<PT> procedureFactory, BatchIterable<T> iterable)
void
executeAndCombine(java.util.concurrent.ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<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
-
taskCount
private final int taskCount
-
-
Method Detail
-
createAndExecuteTasks
private FastList<java.util.concurrent.ForkJoinTask<PT>> createAndExecuteTasks(java.util.concurrent.ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> iterable)
-
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, ProcedureFactory<PT> procedureFactory, BatchIterable<T> list)
-
join
private void join()
-
-