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

public Class FJListObjectIntProcedureRunner<T, PT extends ObjectIntProcedure<? super T>>

extends Object
implements Serializable
Class Inheritance
All Implemented Interfaces
java.io.Serializable
Imports
java.io.Serializable, java.util.List, java.util.concurrent.ArrayBlockingQueue, .BlockingQueue, .ExecutionException, .ForkJoinPool, .ForkJoinTask, org.eclipse.collections.api.block.function.Function, org.eclipse.collections.api.block.procedure.primitive.ObjectIntProcedure, org.eclipse.collections.impl.list.mutable.FastList, org.eclipse.collections.impl.parallel.Combiner, .ObjectIntProcedureFactory

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
FJListObjectIntProcedureRunner.ProcedureExtractor

Field Summary

Modifier and TypeField and 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

AccessConstructor and Description
public
FJListObjectIntProcedureRunner(Combiner<PT> newCombiner, int taskCount)

Method Summary

Modifier and TypeMethod and Description
private FastList<ForkJoinTask<PT>>
createAndExecuteTasks(ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list)

protected FJListObjectIntProcedureTask<T, PT>
createTask(ObjectIntProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index)

public void
executeAndCombine(ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list)

private void
join()

public void
setFailed(Throwable newError)

public void
taskCompleted(ForkJoinTask<PT> task)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

combinerback to summary
private final Combiner<PT> combiner
errorback to summary
private Throwable error
outputQueueback to summary
private final BlockingQueue<PT> outputQueue
serialVersionUIDback to summary
private static final long serialVersionUID
taskCountback to summary
private final int taskCount

Constructor Detail

FJListObjectIntProcedureRunnerback to summary
public FJListObjectIntProcedureRunner(Combiner<PT> newCombiner, int taskCount)

Method Detail

createAndExecuteTasksback to summary
private FastList<ForkJoinTask<PT>> createAndExecuteTasks(ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list)
createTaskback to summary
protected FJListObjectIntProcedureTask<T, PT> createTask(ObjectIntProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index)
executeAndCombineback to summary
public void executeAndCombine(ForkJoinPool executor, ObjectIntProcedureFactory<PT> procedureFactory, List<T> list)
joinback to summary
private void join()
setFailedback to summary
public void setFailed(Throwable newError)
taskCompletedback to summary
public void taskCompleted(ForkJoinTask<PT> task)
org.eclipse.collections.impl.forkjoin back to summary

private final Class FJListObjectIntProcedureRunner.ProcedureExtractor

extends Object
implements Function<ForkJoinTask<PT extends ObjectIntProcedure<? super T>>, PT extends ObjectIntProcedure<? super T>>
Class Inheritance
  • java.lang.Object
  • org.eclipse.collections.impl.forkjoin.FJListObjectIntProcedureRunner.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 PT
valueOf(ForkJoinTask<PT> 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 PT valueOf(ForkJoinTask<PT> object)

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

Annotations
@Override