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 voidFJBatchIterableProcedureRunner. executeAndCombine(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> list)voidFJListProcedureRunner. 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 classCollectIfProcedureFactory<T,V>classCollectProcedureFactory<T,V>classCountProcedureFactory<T>classFastListCollectIfProcedureFactory<T,V>classFastListCollectProcedureFactory<T,V>classFastListRejectProcedureFactory<T>classFastListSelectProcedureFactory<T>classFlatCollectProcedureFactory<T,V>classPassThruProcedureFactory<BT extends Procedure<?>>classRejectProcedureFactory<T>classSelectProcedureFactory<T>Methods in org.eclipse.collections.impl.parallel with parameters of type ProcedureFactory Modifier and Type Method Description voidArrayProcedureFJTaskRunner. executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array)voidBatchIterableProcedureFJTaskRunner. executeAndCombine(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> set)voidProcedureFJTaskRunner. 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.