Uses of Interface
org.eclipse.collections.impl.parallel.Combiner
Packages that use 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
Methods in org.eclipse.collections.impl.forkjoin with parameters of type CombinerModifier 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) Constructors in org.eclipse.collections.impl.forkjoin with parameters of type CombinerModifierConstructorDescriptionFJBatchIterableProcedureRunner(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
Classes in org.eclipse.collections.impl.parallel that implement CombinerModifier and TypeClassDescriptionclassAbstractPredicateBasedCombiner<T, BT extends Procedure<T>>classclassAbstractTransformerBasedCombiner<V, T, BT extends Procedure<T>>final classCombines the results of a Collection of CollectIfBlocks which each hold onto a transformed and filtered (collect, if) collection of results.final classCombines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.final classCombines the results of a Collection of CountBlocks which each hold onto a filtered sum (count where) result.final classCombines the results of a Collection of FastListCollectIfProcedures which each hold onto a transformed and filtered (collect, if) collection of results.final classCombines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.final classCombines the results of a Collection of FastListRejectProcedures which each hold onto a negative filtered (reject) collection of results.final classCombines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.final classCombines the results of a Collection ofFlatCollectProcedures which each hold onto a transformed (flatten) collection of results.final classA PassThruCombiner doesn't do anything.final classCombines the results of a Collection of SelectBlocks which each hold onto a negative filtered (reject) collection of results.final classCombines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.Methods in org.eclipse.collections.impl.parallel that return CombinerMethods in org.eclipse.collections.impl.parallel with parameters of type CombinerModifier 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) Constructors in org.eclipse.collections.impl.parallel with parameters of type CombinerModifierConstructorDescriptionArrayProcedureFJTaskRunner(Combiner<BT> newCombiner, int newTaskCount) BatchIterableProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount) ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount) ProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)