Uses of Interface
org.eclipse.collections.impl.parallel.Combiner
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 Combiner in org.eclipse.collections.impl.forkjoin
Modifier and TypeMethodDescriptionstatic <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) static <T,
PT extends ObjectIntProcedure<? super T>>
voidFJIterate.forEachWithIndex
(Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount) static <T,
PT extends ObjectIntProcedure<? super T>>
voidFJIterate.forEachWithIndex
(Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor) static <T,
PT extends ObjectIntProcedure<? super T>>
voidFJIterate.forEachWithIndex
(Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, ForkJoinPool executor) static <T,
PT extends ObjectIntProcedure<? super T>>
voidFJIterate.forEachWithIndexInListOnExecutor
(List<T> list, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor) ModifierConstructorDescriptionFJBatchIterableProcedureRunner
(Combiner<PT> newCombiner, int taskCount) FJListObjectIntProcedureRunner
(Combiner<PT> newCombiner, int taskCount) FJListProcedureRunner
(Combiner<PT> newCombiner, int taskCount) -
Uses of Combiner in org.eclipse.collections.impl.parallel
Modifier and TypeClassDescriptionclass
AbstractPredicateBasedCombiner<T,
BT extends Procedure<T>> class
class
AbstractTransformerBasedCombiner<V,
T, BT extends Procedure<T>> final class
Combines the results of a Collection of CollectIfBlocks which each hold onto a transformed and filtered (collect, if) collection of results.final class
Combines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.final class
Combines the results of a Collection of CountBlocks which each hold onto a filtered sum (count where) result.final class
Combines the results of a Collection of FastListCollectIfProcedures which each hold onto a transformed and filtered (collect, if) collection of results.final class
Combines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.final class
Combines the results of a Collection of FastListRejectProcedures which each hold onto a negative filtered (reject) collection of results.final class
Combines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.final class
Combines the results of a Collection ofFlatCollectProcedure
s which each hold onto a transformed (flatten) collection of results.final class
A PassThruCombiner doesn't do anything.final class
Combines the results of a Collection of SelectBlocks which each hold onto a negative filtered (reject) collection of results.final class
Combines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.Modifier and TypeMethodDescriptionstatic <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) static <T,
BT extends ObjectIntProcedure<? super T>>
voidParallelIterate.forEachWithIndex
(Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount) static <T,
BT extends ObjectIntProcedure<? super T>>
voidParallelIterate.forEachWithIndex
(Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor) static <T,
BT extends ObjectIntProcedure<? super T>>
voidParallelIterate.forEachWithIndex
(Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, Executor executor) static <T,
BT extends ObjectIntProcedure<? super T>>
voidParallelIterate.forEachWithIndexInListOnExecutor
(List<T> list, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor) ModifierConstructorDescriptionArrayProcedureFJTaskRunner
(Combiner<BT> newCombiner, int newTaskCount) BatchIterableProcedureFJTaskRunner
(Combiner<BT> newCombiner, int taskCount) ObjectIntProcedureFJTaskRunner
(Combiner<BT> newCombiner, int taskCount) ProcedureFJTaskRunner
(Combiner<BT> newCombiner, int taskCount)