Top Fields Constructors Methods
org.eclipse.collections.impl.forkjoin

public Class FJBatchIterableProcedureTask<T, PT extends Procedure<? super T>>

extends ForkJoinTask<PT extends Procedure<? super T>>
Class Inheritance
Imports
java.util.concurrent.ForkJoinTask, org.eclipse.collections.api.block.procedure.Procedure, org.eclipse.collections.impl.parallel.BatchIterable, .ProcedureFactory

Field Summary

Modifier and TypeField and Description
private 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

AccessConstructor and Description
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 Summary

Modifier and TypeMethod and Description
protected boolean
exec()

Implements abstract java.util.concurrent.ForkJoinTask.exec.

Immediately performs the base action of this task and returns true if, upon return from this method, this task is guaranteed to have completed.

public PT
getRawResult()

Implements abstract java.util.concurrent.ForkJoinTask.getRawResult.

Returns the result that would be returned by join, even if this task completed abnormally, or null if this task is not known to have been completed.

protected void
setRawResult(PT value)

Implements abstract java.util.concurrent.ForkJoinTask.setRawResult.

Forces the given value to be returned as a result.

Inherited from java.util.concurrent.ForkJoinTask:
adaptadaptadaptadaptInterruptibleadaptInterruptibleadaptInterruptiblecancelcompareAndSetForkJoinTaskTagcompletecompleteExceptionallyexceptionNowforkgetgetgetExceptiongetForkJoinTaskTaggetPoolgetQueuedTaskCountgetSurplusQueuedTaskCounthelpQuiesceinForkJoinPoolinvokeinvokeAllinvokeAllinvokeAllisCancelledisCompletedAbnormallyisCompletedNormallyisDonejoinpeekNextLocalTaskpollNextLocalTaskpollSubmissionpollTaskquietlyCompletequietlyInvokequietlyJoinquietlyJoinquietlyJoinUninterruptiblyreinitializeresultNowsetForkJoinTaskTagstatetryUnfork

Field Detail

iterableback to summary
private final BatchIterable<T> iterable
procedureback to summary
private PT procedure
procedureFactoryback to summary
private final ProcedureFactory<PT> procedureFactory
sectionCountback to summary
private final int sectionCount
sectionIndexback to summary
private final int sectionIndex
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.ForkJoinTask.serialVersionUID.

taskRunnerback to summary
private final FJBatchIterableProcedureRunner<T, PT> taskRunner

Constructor Detail

FJBatchIterableProcedureTaskback to summary
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

execback to summary
protected boolean exec()

Implements abstract java.util.concurrent.ForkJoinTask.exec.

Doc from java.util.concurrent.ForkJoinTask.exec.

Immediately performs the base action of this task and returns true if, upon return from this method, this task is guaranteed to have completed. This method may return false otherwise, to indicate that this task is not necessarily complete (or is not known to be complete), for example in asynchronous actions that require explicit invocations of completion methods. This method may also throw an (unchecked) exception to indicate abnormal exit. This method is designed to support extensions, and should not in general be called otherwise.

Annotations
@Override
getRawResultback to summary
public PT getRawResult()

Implements abstract java.util.concurrent.ForkJoinTask.getRawResult.

Doc from java.util.concurrent.ForkJoinTask.getRawResult.

Returns the result that would be returned by join, even if this task completed abnormally, or null if this task is not known to have been completed. This method is designed to aid debugging, as well as to support extensions. Its use in any other context is discouraged.

Annotations
@Override
setRawResultback to summary
protected void setRawResult(PT value)

Implements abstract java.util.concurrent.ForkJoinTask.setRawResult.

Doc from java.util.concurrent.ForkJoinTask.setRawResult.

Forces the given value to be returned as a result. This method is designed to support extensions, and should not in general be called otherwise.

Annotations
@Override