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

java.lang.Object

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

public final class ArrayProcedureFJTaskRunner<T, BT extends Procedure<? super T>>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	ArrayProcedureFJTaskRunner.ProcedureExtractor

Field Summary

Fields

Modifier and Type	Field	Description
private final Combiner<BT>	combiner
private Throwable	error
private final CountDownLatch	latch
private final BlockingQueue<BT>	outputQueue
private final Function<ArrayProcedureFJTask<T,BT>, BT>	procedureFunction
private ArrayProcedureFJTask<T,BT>[]	procedures
private final int	taskCount

Constructor Summary

Constructors

Constructor	Description
ArrayProcedureFJTaskRunner(Combiner<BT> newCombiner, int newTaskCount)

Method Summary

Modifier and Type	Method	Description
private void	combineTasks()
private void	createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array)	Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
void	executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array)
private void	join()
void	setFailed(Throwable newError)
void	taskCompleted(ArrayProcedureFJTask<T,BT> task)

Methods inherited from class Object

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

Field Details

procedureFunction

private final Function<ArrayProcedureFJTask<T, BT extends Procedure<? super T>>, BT extends Procedure<? super T>> procedureFunction

procedures

private ArrayProcedureFJTask<T, BT extends Procedure<? super T>>[] procedures

error

private Throwable error

latch

private final CountDownLatch latch

combiner

private final Combiner<BT extends Procedure<? super T>> combiner

outputQueue

private final BlockingQueue<BT extends Procedure<? super T>> outputQueue

taskCount

private final int taskCount

Constructor Details

ArrayProcedureFJTaskRunner

public ArrayProcedureFJTaskRunner(Combiner<BT> newCombiner,
 int newTaskCount)

Method Details

createAndExecuteTasks

private void createAndExecuteTasks(Executor executor,
 ProcedureFactory<BT> procedureFactory,
 T[] array)

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

taskCompleted

public void taskCompleted(ArrayProcedureFJTask<T,BT> task)

join

private void join()

executeAndCombine

public void executeAndCombine(Executor executor,
 ProcedureFactory<BT> procedureFactory,
 T[] array)

setFailed

public void setFailed(Throwable newError)

combineTasks

private void combineTasks()