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

public final Class BatchIterableProcedureFJTaskRunner<T, BT extends Procedure<? super T>>

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

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
BatchIterableProcedureFJTaskRunner.ProcedureExtractor

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<BatchIterableProcedureFJTask<T, BT>, BT>
procedureFunction

private BatchIterableProcedureFJTask<T, BT>[]
procedures

private final int
taskCount

Constructor Summary

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

Method Summary

Modifier and TypeMethod and Description
private void
combineTasks()

private void
createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> batchIterable)

public void
executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> set)

private void
join()

public void
setFailed(Throwable newError)

public void
taskCompleted(BatchIterableProcedureFJTask<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<BatchIterableProcedureFJTask<T, BT>, BT> procedureFunction
proceduresback to summary
private BatchIterableProcedureFJTask<T, BT>[] procedures
taskCountback to summary
private final int taskCount

Constructor Detail

BatchIterableProcedureFJTaskRunnerback to summary
public BatchIterableProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)

Method Detail

combineTasksback to summary
private void combineTasks()
createAndExecuteTasksback to summary
private void createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> batchIterable)
executeAndCombineback to summary
public void executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> set)
joinback to summary
private void join()
setFailedback to summary
public void setFailed(Throwable newError)
taskCompletedback to summary
public void taskCompleted(BatchIterableProcedureFJTask<T, BT> task)
org.eclipse.collections.impl.parallel back to summary

private final Class BatchIterableProcedureFJTaskRunner.ProcedureExtractor

extends Object
implements Function<BatchIterableProcedureFJTask<T, BT extends Procedure<? super T>>, BT extends Procedure<? super T>>
Class Inheritance
  • java.lang.Object
  • org.eclipse.collections.impl.parallel.BatchIterableProcedureFJTaskRunner.ProcedureExtractor
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
ProcedureExtractor()

Method Summary

Modifier and TypeMethod and Description
public BT
valueOf(BatchIterableProcedureFJTask<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

ProcedureExtractorback to summary
private ProcedureExtractor()

Method Detail

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

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

Annotations
@Override