Uses of Interface
org.eclipse.collections.impl.parallel.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
Methods in org.eclipse.collections.impl.forkjoin with parameters of type ProcedureFactory Modifier and Type Method Description void
FJBatchIterableProcedureRunner. executeAndCombine(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> list)
void
FJListProcedureRunner. executeAndCombine(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, List<T> list)
static <T, PT extends Procedure<? super T>>
voidFJIterate. forEach(Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner)
static <T, PT extends Procedure<? super T>>
voidFJIterate. forEach(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(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(Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>>
voidFJIterate. forEach(Iterable<T> iterable, ProcedureFactory<PT> blockFactory, Combiner<PT> combiner, int batchSize, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>>
voidFJIterate. forEach(Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>>
voidFJIterate. forEachInBatchWithExecutor(BatchIterable<T> batchIterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>>
voidFJIterate. forEachInListOnExecutor(List<T> list, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, 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, 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>
class
PassThruProcedureFactory<BT extends Procedure<?>>
class
RejectProcedureFactory<T>
class
SelectProcedureFactory<T>
Methods in org.eclipse.collections.impl.parallel with parameters of type ProcedureFactory Modifier and Type Method Description void
ArrayProcedureFJTaskRunner. executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array)
void
BatchIterableProcedureFJTaskRunner. executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> set)
void
ProcedureFJTaskRunner. executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, 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(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T, BT extends Procedure<? super T>>
voidParallelIterate. forEach(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(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(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends Procedure<? super T>>
voidParallelIterate. forEach(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int batchSize, Executor executor)
static <T, BT extends Procedure<? super T>>
voidParallelIterate. forEach(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, Executor executor)
static <T, BT extends Procedure<? super T>>
voidParallelIterate. forEachInBatchWithExecutor(BatchIterable<T> set, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends Procedure<? super T>>
voidParallelIterate. forEachInListOnExecutor(List<T> list, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends Procedure<? super T>>
voidParallelArrayIterate. forEachOn(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, 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, List<T> list, int index, int sectionSize, boolean isLast)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.