Class BatchIterableProcedureFJTask<T, BT extends Procedure<? super T>>

java.lang.Object

org.eclipse.collections.impl.parallel.BatchIterableProcedureFJTask<T,BT>

All Implemented Interfaces:

Runnable

public final class BatchIterableProcedureFJTask<T, BT extends Procedure<? super T>>
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final BatchIterable<T>	iterable
private BT	procedure
private final ProcedureFactory<BT>	procedureFactory
private final int	sectionCount
private final int	sectionIndex
private final BatchIterableProcedureFJTaskRunner<T,BT>	taskRunner

Constructor Summary

Constructors

Constructor	Description
BatchIterableProcedureFJTask(BatchIterableProcedureFJTaskRunner<T,BT> newFJTaskRunner, ProcedureFactory<BT> procedureFactory, 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
BT	getProcedure()
void	run()

Methods inherited from class Object

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

Field Details

procedureFactory

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

procedure

private BT extends Procedure<? super T> procedure

iterable

private final BatchIterable<T> iterable

sectionIndex

private final int sectionIndex

sectionCount

private final int sectionCount

taskRunner

private final BatchIterableProcedureFJTaskRunner<T, BT extends Procedure<? super T>> taskRunner

Constructor Details

BatchIterableProcedureFJTask

public BatchIterableProcedureFJTask(BatchIterableProcedureFJTaskRunner<T,BT> newFJTaskRunner,
 ProcedureFactory<BT> procedureFactory,
 BatchIterable<T> iterable,
 int index,
 int count)

Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.

Method Details

run

public void run()

Specified by:

run in interface Runnable

getProcedure

public BT getProcedure()