Class FJBatchIterableProcedureTask<T,PT extends Procedure<? super T>>
- java.lang.Object
-
- java.util.concurrent.ForkJoinTask<PT>
-
- org.eclipse.collections.impl.forkjoin.FJBatchIterableProcedureTask<T,PT>
-
- All Implemented Interfaces:
java.io.Serializable
,java.util.concurrent.Future<PT>
public class FJBatchIterableProcedureTask<T,PT extends Procedure<? super T>> extends java.util.concurrent.ForkJoinTask<PT>
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description private BatchIterable<T>
iterable
private PT
procedure
private ProcedureFactory<PT>
procedureFactory
private int
sectionCount
private int
sectionIndex
private static long
serialVersionUID
private FJBatchIterableProcedureRunner<T,PT>
taskRunner
-
Constructor Summary
Constructors Constructor Description FJBatchIterableProcedureTask(FJBatchIterableProcedureRunner<T,PT> newFJTaskRunner, ProcedureFactory<PT> newProcedureFactory, BatchIterable<T> iterable, int index, int count)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected boolean
exec()
PT
getRawResult()
protected void
setRawResult(PT value)
-
Methods inherited from class java.util.concurrent.ForkJoinTask
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollSubmission, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
procedureFactory
private final ProcedureFactory<PT extends Procedure<? super T>> procedureFactory
-
iterable
private final BatchIterable<T> iterable
-
sectionIndex
private final int sectionIndex
-
sectionCount
private final int sectionCount
-
taskRunner
private final FJBatchIterableProcedureRunner<T,PT extends Procedure<? super T>> taskRunner
-
-
Constructor Detail
-
FJBatchIterableProcedureTask
public FJBatchIterableProcedureTask(FJBatchIterableProcedureRunner<T,PT> newFJTaskRunner, ProcedureFactory<PT> newProcedureFactory, BatchIterable<T> iterable, int index, int count)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
-
-
Method Detail
-
exec
protected boolean exec()
-
getRawResult
public PT getRawResult()
-
-