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
Fields in org.eclipse.collections.impl.forkjoin declared as ProcedureFactoryModifier and TypeFieldDescriptionprivate final ProcedureFactory<PT> FJBatchIterableProcedureTask.procedureFactoryprivate final ProcedureFactory<PT> FJListProcedureTask.procedureFactoryMethods in org.eclipse.collections.impl.forkjoin with parameters of type ProcedureFactoryModifier and TypeMethodDescriptionprivate FastList<ForkJoinTask<PT>> FJBatchIterableProcedureRunner.createAndExecuteTasks(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, BatchIterable<T> iterable) private FastList<ForkJoinTask<PT>> FJListProcedureRunner.createAndExecuteTasks(ForkJoinPool executor, ProcedureFactory<PT> procedureFactory, List<T> list) protected FJListProcedureTask<T, PT> FJListProcedureRunner.createTask(ProcedureFactory<PT> procedureFactory, List<T> list, int sectionSize, int taskCountMinusOne, int index) 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 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 classfinal classfinal classfinal classfinal classfinal classfinal classfinal classprivate static final classprivate static final classprivate static final classprivate static final classprivate static final classprivate static final classfinal classPassThruProcedureFactory<BT extends Procedure<?>>final classfinal classFields in org.eclipse.collections.impl.parallel declared as ProcedureFactoryModifier and TypeFieldDescriptionprivate final ProcedureFactory<BT> ArrayProcedureFJTask.procedureFactoryprivate final ProcedureFactory<BT> BatchIterableProcedureFJTask.procedureFactoryprivate final ProcedureFactory<BT> ProcedureFJTask.procedureFactoryMethods in org.eclipse.collections.impl.parallel with parameters of type ProcedureFactoryModifier and TypeMethodDescriptionprivate voidArrayProcedureFJTaskRunner.createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, T[] array) Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.private voidBatchIterableProcedureFJTaskRunner.createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, BatchIterable<T> batchIterable) private voidProcedureFJTaskRunner.createAndExecuteTasks(Executor executor, ProcedureFactory<BT> procedureFactory, List<T> list) 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 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.