Top Inners Fields Constructors Methods
org.eclipse.collections.impl.parallel

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

extends Object
Class Inheritance
Imports
java.util.List, java.util.concurrent.ArrayBlockingQueue, .BlockingQueue, .CountDownLatch, .Executor, org.eclipse.collections.api.block.function.Function, org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure, org.eclipse.collections.impl.utility.ArrayIterate

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
ObjectIntProcedureFJTaskRunner.ObjectIntProcedureExtractor

Field Summary

Modifier and TypeField and Description
private final Combiner<BT>
combiner

private Throwable
error

private final CountDownLatch
latch

private final BlockingQueue<BT>
outputQueue

private final Function<ObjectIntProcedureFJTask<T, BT>, BT>
procedureFunction

private ObjectIntProcedureFJTask<T, BT>[]
procedures

private final int
taskCount

Constructor Summary

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

pack-priv
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount, BlockingQueue<BT> queue, CountDownLatch latch)

Method Summary

Modifier and TypeMethod and Description
private static <BT> CountDownLatch
buildCountDownLatch(Combiner<BT> newCombiner, int taskCount)

private static <BT> ArrayBlockingQueue<BT>
buildQueue(Combiner<BT> newCombiner, int taskCount)

private void
combineTasks()

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

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

private void
join()

public void
setFailed(Throwable newError)

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

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

combinerback to summary
private final Combiner<BT> combiner
errorback to summary
private Throwable error
latchback to summary
private final CountDownLatch latch
outputQueueback to summary
private final BlockingQueue<BT> outputQueue
procedureFunctionback to summary
private final Function<ObjectIntProcedureFJTask<T, BT>, BT> procedureFunction
proceduresback to summary
private ObjectIntProcedureFJTask<T, BT>[] procedures
taskCountback to summary
private final int taskCount

Constructor Detail

ObjectIntProcedureFJTaskRunnerback to summary
public ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)
ObjectIntProcedureFJTaskRunnerback to summary
pack-priv ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount, BlockingQueue<BT> queue, CountDownLatch latch)

Method Detail

buildCountDownLatchback to summary
private static <BT> CountDownLatch buildCountDownLatch(Combiner<BT> newCombiner, int taskCount)
buildQueueback to summary
private static <BT> ArrayBlockingQueue<BT> buildQueue(Combiner<BT> newCombiner, int taskCount)
combineTasksback to summary
private void combineTasks()
createAndExecuteTasksback to summary
private void createAndExecuteTasks(Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, List<T> list)
executeAndCombineback to summary
public void executeAndCombine(Executor executor, ObjectIntProcedureFactory<BT> procedureFactory, List<T> list)
joinback to summary
private void join()
setFailedback to summary
public void setFailed(Throwable newError)
taskCompletedback to summary
public void taskCompleted(ObjectIntProcedureFJTask<T, BT> task)
org.eclipse.collections.impl.parallel back to summary

private final Class ObjectIntProcedureFJTaskRunner.ObjectIntProcedureExtractor

extends Object
implements Function<ObjectIntProcedureFJTask<T, BT extends ObjectIntProcedure<? super T>>, BT extends ObjectIntProcedure<? super T>>
Class Inheritance
  • java.lang.Object
  • org.eclipse.collections.impl.parallel.ObjectIntProcedureFJTaskRunner.ObjectIntProcedureExtractor
All Implemented Interfaces
org.eclipse.collections.api.block.function.Function, java.io.Serializable, java.util.function.Function

Field Summary

Modifier and TypeField and Description
private static final long
serialVersionUID

Constructor Summary

AccessConstructor and Description
private
ObjectIntProcedureExtractor()

Method Summary

Modifier and TypeMethod and Description
public BT
valueOf(ObjectIntProcedureFJTask<T, BT> object)

Implements org.eclipse.collections.api.block.function.Function.valueOf.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

serialVersionUIDback to summary
private static final long serialVersionUID

Constructor Detail

ObjectIntProcedureExtractorback to summary
private ObjectIntProcedureExtractor()

Method Detail

valueOfback to summary
public BT valueOf(ObjectIntProcedureFJTask<T, BT> object)

Implements org.eclipse.collections.api.block.function.Function.valueOf.

Annotations
@Override