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