Uses of Interface
org.eclipse.collections.impl.parallel.ProcedureFactory
Packages that use ProcedureFactory
Package
Description
This package contains implementations which has several parallel algorithms that work with Collections and make use of Java's fork-join
framework.
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 ProcedureFactoryModifier and TypeMethodDescriptionvoid
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 ProcedureFactoryModifierConstructorDescriptionFJBatchIterableProcedureTask
(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 ProcedureFactoryModifier and TypeClassDescriptionfinal class
final class
final class
final class
final class
final class
final class
final class
final class
PassThruProcedureFactory<BT extends Procedure<?>>
final class
final class
Methods in org.eclipse.collections.impl.parallel with parameters of type ProcedureFactoryModifier and TypeMethodDescriptionvoid
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 ProcedureFactoryModifierConstructorDescriptionArrayProcedureFJTask
(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.