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:
Serializable
,Future<PT>
public class FJBatchIterableProcedureTask<T,PT extends Procedure<? super T>>
extends ForkJoinTask<PT>
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from interface java.util.concurrent.Future
Future.State
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final BatchIterable
<T> private PT
private final ProcedureFactory
<PT> private final int
private final int
private static final long
private final FJBatchIterableProcedureRunner
<T, PT> -
Constructor Summary
ConstructorsConstructorDescriptionFJBatchIterableProcedureTask
(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
Methods inherited from class java.util.concurrent.ForkJoinTask
adapt, adapt, adapt, adaptInterruptible, cancel, compareAndSetForkJoinTaskTag, complete, completeExceptionally, exceptionNow, 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, quietlyJoin, quietlyJoinUninterruptibly, reinitialize, resultNow, setForkJoinTaskTag, state, tryUnfork
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
procedureFactory
-
procedure
-
iterable
-
sectionIndex
private final int sectionIndex -
sectionCount
private final int sectionCount -
taskRunner
-
-
Constructor Details
-
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 Details
-
exec
protected boolean exec()- Specified by:
exec
in classForkJoinTask<PT extends Procedure<? super T>>
-
getRawResult
- Specified by:
getRawResult
in classForkJoinTask<PT extends Procedure<? super T>>
-
setRawResult
- Specified by:
setRawResult
in classForkJoinTask<PT extends Procedure<? super T>>
-