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:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
private final BatchIterable<T>	iterable
private PT	procedure
private final ProcedureFactory<PT>	procedureFactory
private final int	sectionCount
private final int	sectionIndex
private static final long	serialVersionUID
private final 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

Modifier and Type	Method	Description
protected boolean	exec()
PT	getRawResult()
protected void	setRawResult(PT value)

Methods inherited from class ForkJoinTask

adapt, adapt, adapt, adaptInterruptible, adaptInterruptible, 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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

procedureFactory

private final ProcedureFactory<PT extends Procedure<? super T>> procedureFactory

procedure

private PT extends Procedure<? super T> procedure

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 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 class ForkJoinTask<PT extends Procedure<? super T>>

getRawResult

public PT getRawResult()

Specified by:

getRawResult in class ForkJoinTask<PT extends Procedure<? super T>>

setRawResult

protected void setRawResult(PT value)

Specified by:

setRawResult in class ForkJoinTask<PT extends Procedure<? super T>>