Uses of Interface
org.eclipse.collections.impl.parallel.ProcedureFactory
-
Packages that use ProcedureFactory Package Description org.eclipse.collections.impl.forkjoin This package contains implementations which has several parallel algorithms that work with Collections and make use of Java's fork-join framework.org.eclipse.collections.impl.parallel This package contains classes which is used for parallel iteration through the containers. -
-
Uses of ProcedureFactory in org.eclipse.collections.impl.forkjoin
Fields in org.eclipse.collections.impl.forkjoin declared as ProcedureFactory Modifier and Type Field Description private ProcedureFactory<PT>
FJBatchIterableProcedureTask. procedureFactory
private ProcedureFactory<PT>
FJListProcedureTask. procedureFactory
Methods in org.eclipse.collections.impl.forkjoin with parameters of type ProcedureFactory Modifier and Type Method Description private FastList<java.util.concurrent.ForkJoinTask<PT>>
FJBatchIterableProcedureRunner. createAndExecuteTasks(java.util.concurrent.ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> iterable)
private FastList<java.util.concurrent.ForkJoinTask<PT>>
FJListProcedureRunner. createAndExecuteTasks(java.util.concurrent.ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, java.util.List<T> list)
protected FJListProcedureTask<T,PT>
FJListProcedureRunner. createTask(ProcedureFactory<PT> procedureFactory, java.util.List<T> list, int sectionSize, int taskCountMinusOne, int index)
void
FJBatchIterableProcedureRunner. executeAndCombine(java.util.concurrent.ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> list)
void
FJListProcedureRunner. executeAndCombine(java.util.concurrent.ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, java.util.List<T> list)
static <T,PT extends Procedure<? super T>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner)
static <T,PT extends Procedure<? super T>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int batchSize)
Iterate over the collection specified in parallel batches using the default values for the task size.static <T,PT extends Procedure<? super T>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount)
Iterate over the collection specified in parallel batches using the default values for the task size.static <T,PT extends Procedure<? super T>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> blockFactory, Combiner<PT> combiner, int batchSize, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>>
voidFJIterate. forEachInBatchWithExecutor(BatchIterable<T> batchIterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>>
voidFJIterate. forEachInListOnExecutor(java.util.List<T> list, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)
Constructors in org.eclipse.collections.impl.forkjoin with parameters of type ProcedureFactory Constructor Description FJBatchIterableProcedureTask(FJBatchIterableProcedureRunner<T,PT> newFJTaskRunner, ProcedureFactory<PT> newProcedureFactory, BatchIterable<T> iterable, int index, int count)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.FJListProcedureTask(FJListProcedureRunner<T,PT> newFJTaskRunner, ProcedureFactory<PT> newProcedureFactory, java.util.List<T> list, int index, int sectionSize, boolean isLast)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory. -
Uses of ProcedureFactory in org.eclipse.collections.impl.parallel
Classes in org.eclipse.collections.impl.parallel that implement ProcedureFactory Modifier and Type Class Description class
CollectIfProcedureFactory<T,V>
class
CollectProcedureFactory<T,V>
class
CountProcedureFactory<T>
class
FastListCollectIfProcedureFactory<T,V>
class
FastListCollectProcedureFactory<T,V>
class
FastListRejectProcedureFactory<T>
class
FastListSelectProcedureFactory<T>
class
FlatCollectProcedureFactory<T,V>
private static class
ParallelIterate.SumByBigDecimalProcedure<T,V>
private static class
ParallelIterate.SumByBigIntegerProcedure<T,V>
private static class
ParallelIterate.SumByDoubleProcedure<T,V>
private static class
ParallelIterate.SumByFloatProcedure<T,V>
private static class
ParallelIterate.SumByIntProcedure<T,V>
private static class
ParallelIterate.SumByLongProcedure<T,V>
class
PassThruProcedureFactory<BT extends Procedure<?>>
class
RejectProcedureFactory<T>
class
SelectProcedureFactory<T>
Fields in org.eclipse.collections.impl.parallel declared as ProcedureFactory Modifier and Type Field Description private ProcedureFactory<BT>
ArrayProcedureFJTask. procedureFactory
private ProcedureFactory<BT>
BatchIterableProcedureFJTask. procedureFactory
private ProcedureFactory<BT>
ProcedureFJTask. procedureFactory
Methods in org.eclipse.collections.impl.parallel with parameters of type ProcedureFactory Modifier and Type Method Description private void
ArrayProcedureFJTaskRunner. createAndExecuteTasks(java.util.concurrent.Executor executor, ProcedureFactory<BT> procedureFactory, T[] array)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.private void
BatchIterableProcedureFJTaskRunner. createAndExecuteTasks(java.util.concurrent.Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> batchIterable)
private void
ProcedureFJTaskRunner. createAndExecuteTasks(java.util.concurrent.Executor executor, ProcedureFactory<BT> procedureFactory, java.util.List<T> list)
void
ArrayProcedureFJTaskRunner. executeAndCombine(java.util.concurrent.Executor executor, ProcedureFactory<BT> procedureFactory, T[] array)
void
BatchIterableProcedureFJTaskRunner. executeAndCombine(java.util.concurrent.Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> set)
void
ProcedureFJTaskRunner. executeAndCombine(java.util.concurrent.Executor executor, ProcedureFactory<BT> procedureFactory, java.util.List<T> list)
static <T,BT extends Procedure<? super T>>
voidParallelArrayIterate. forEach(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T,BT extends Procedure<? super T>>
voidParallelArrayIterate. forEach(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int batchSize)
Iterate over the collection specified in parallel batches using the default values for the task size.static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount)
Iterate over the collection specified in parallel batches using the default values for the task size.static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int batchSize, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEachInBatchWithExecutor(BatchIterable<T> set, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. forEachInListOnExecutor(java.util.List<T> list, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>>
voidParallelArrayIterate. forEachOn(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
Constructors in org.eclipse.collections.impl.parallel with parameters of type ProcedureFactory Constructor Description ArrayProcedureFJTask(ArrayProcedureFJTaskRunner<T,BT> newFJTaskRunner, ProcedureFactory<BT> procedureFactory, T[] newArray, int newIndex, int newSectionSize, boolean isLast)
BatchIterableProcedureFJTask(BatchIterableProcedureFJTaskRunner<T,BT> newFJTaskRunner, ProcedureFactory<BT> procedureFactory, BatchIterable<T> iterable, int index, int count)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.ProcedureFJTask(ProcedureFJTaskRunner<T,BT> newFJTaskRunner, ProcedureFactory<BT> newProcedureFactory, java.util.List<T> list, int index, int sectionSize, boolean isLast)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
-