Class FJBatchIterableProcedureRunner<T, PT extends Procedure<? super T>>

java.lang.Object

org.eclipse.collections.impl.forkjoin.FJBatchIterableProcedureRunner<T,PT>

All Implemented Interfaces:

Serializable

public class FJBatchIterableProcedureRunner<T, PT extends Procedure<? super T>>
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	FJBatchIterableProcedureRunner.ProcedureExtractor

Field Summary

Fields

Modifier and Type	Field	Description
private final Combiner<PT>	combiner
private Throwable	error
private final BlockingQueue<PT>	outputQueue
private static final long	serialVersionUID
private final int	taskCount

Constructor Summary

Constructors

Constructor	Description
FJBatchIterableProcedureRunner(Combiner<PT> newCombiner, int taskCount)

Method Summary

Modifier and Type	Method	Description
private FastList<ForkJoinTask<PT>>	createAndExecuteTasks(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> iterable)
void	executeAndCombine(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> list)
private void	join()
void	setFailed(Throwable newError)
void	taskCompleted(ForkJoinTask<PT> task)

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

error

private Throwable error

combiner

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

taskCount

private final int taskCount

outputQueue

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

Constructor Details

FJBatchIterableProcedureRunner

public FJBatchIterableProcedureRunner(Combiner<PT> newCombiner,
 int taskCount)

Method Details

createAndExecuteTasks

private FastList<ForkJoinTask<PT>> createAndExecuteTasks(ForkJoinPool executor,
 ProcedureFactory<PT> procedureFactory,
 BatchIterable<T> iterable)

setFailed

public void setFailed(Throwable newError)

taskCompleted

public void taskCompleted(ForkJoinTask<PT> task)

executeAndCombine

public void executeAndCombine(ForkJoinPool executor,
 ProcedureFactory<PT> procedureFactory,
 BatchIterable<T> list)

join

private void join()