Package org.eclipse.collections.impl.parallel

Class ObjectIntProcedureFJTaskRunner<T,BT extends ObjectIntProcedure<? super T>>

java.lang.Object

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

public final class ObjectIntProcedureFJTaskRunner<T,BT extends ObjectIntProcedure<? super T>>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ObjectIntProcedureFJTaskRunner.ObjectIntProcedureExtractor

Field Summary

Fields

Modifier and Type	Field	Description
private Combiner<BT>	combiner
private java.lang.Throwable	error
private java.util.concurrent.CountDownLatch	latch
private java.util.concurrent.BlockingQueue<BT>	outputQueue
private Function<ObjectIntProcedureFJTask<T,BT>,BT>	procedureFunction
private ObjectIntProcedureFJTask<T,BT>[]	procedures
private int	taskCount

Constructor Summary

Constructors

Constructor	Description
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount, java.util.concurrent.BlockingQueue<BT> queue, java.util.concurrent.CountDownLatch latch)

Method Summary

Modifier and Type	Method	Description
private static <BT> java.util.concurrent.CountDownLatch	buildCountDownLatch(Combiner<BT> newCombiner, int taskCount)
private static <BT> java.util.concurrent.ArrayBlockingQueue<BT>	buildQueue(Combiner<BT> newCombiner, int taskCount)
private void	combineTasks()
private void	createAndExecuteTasks(java.util.concurrent.Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, java.util.List<T> list)
void	executeAndCombine(java.util.concurrent.Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, java.util.List<T> list)
private void	join()
void	setFailed(java.lang.Throwable newError)
void	taskCompleted(ObjectIntProcedureFJTask<T,BT> task)

Methods inherited from class java.lang.Object

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

Field Detail

procedureFunction

private final Function<ObjectIntProcedureFJTask<T,BT extends ObjectIntProcedure<? super T>>,BT extends ObjectIntProcedure<? super T>> procedureFunction

procedures

private ObjectIntProcedureFJTask<T,BT extends ObjectIntProcedure<? super T>>[] procedures

error

private java.lang.Throwable error

combiner

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

taskCount

private final int taskCount

outputQueue

private final java.util.concurrent.BlockingQueue<BT extends ObjectIntProcedure<? super T>> outputQueue

latch

private final java.util.concurrent.CountDownLatch latch

Constructor Detail

ObjectIntProcedureFJTaskRunner

public ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner,
                                      int taskCount)

ObjectIntProcedureFJTaskRunner

ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner,
                               int taskCount,
                               java.util.concurrent.BlockingQueue<BT> queue,
                               java.util.concurrent.CountDownLatch latch)

Method Detail

buildCountDownLatch

private static <BT> java.util.concurrent.CountDownLatch buildCountDownLatch(Combiner<BT> newCombiner,
                                                                            int taskCount)

buildQueue

private static <BT> java.util.concurrent.ArrayBlockingQueue<BT> buildQueue(Combiner<BT> newCombiner,
                                                                           int taskCount)

createAndExecuteTasks

private void createAndExecuteTasks(java.util.concurrent.Executor executor,
                                   ObjectIntProcedureFactory<BT> procedureFactory,
                                   java.util.List<T> list)

setFailed

public void setFailed(java.lang.Throwable newError)

taskCompleted

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

executeAndCombine

public void executeAndCombine(java.util.concurrent.Executor executor,
                              ObjectIntProcedureFactory<BT> procedureFactory,
                              java.util.List<T> list)

join

private void join()

combineTasks

private void combineTasks()