Uses of Interface
org.eclipse.collections.impl.parallel.Combiner

Packages that use Combiner

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 Combiner in org.eclipse.collections.impl.forkjoin

Fields in org.eclipse.collections.impl.forkjoin declared as Combiner

Modifier and Type	Field	Description
private final Combiner<PT>	FJBatchIterableProcedureRunner.combiner
private final Combiner<PT>	FJListObjectIntProcedureRunner.combiner
private final Combiner<PT>	FJListProcedureRunner.combiner

Methods in org.eclipse.collections.impl.forkjoin with parameters of type Combiner

Modifier and Type	Method	Description
static <T, PT extends Procedure<? super T>> void	FJIterate.forEach(Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner)
static <T, PT extends Procedure<? super T>> void	FJIterate.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>> void	FJIterate.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>> void	FJIterate.forEach(Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>> void	FJIterate.forEach(Iterable<T> iterable, ProcedureFactory<PT> blockFactory, Combiner<PT> combiner, int batchSize, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>> void	FJIterate.forEach(Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>> void	FJIterate.forEachInBatchWithExecutor(BatchIterable<T> batchIterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor)
static <T, PT extends Procedure<? super T>> void	FJIterate.forEachInListOnExecutor(List<T> list, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor)
static <T, PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndex(Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount)
static <T, PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndex(Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, ForkJoinPool executor)
static <T, PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndex(Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, ForkJoinPool executor)
static <T, PT extends ObjectIntProcedure<? super T>> void	FJIterate.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 Combiner

Modifier	Constructor	Description
	FJBatchIterableProcedureRunner(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 Combiner

Modifier and Type	Class	Description
class	AbstractPredicateBasedCombiner<T, BT extends Procedure<T>>
class	AbstractProcedureCombiner<BT>
class	AbstractTransformerBasedCombiner<V, T, BT extends Procedure<T>>
final class	CollectIfProcedureCombiner<T,V>	Combines the results of a Collection of CollectIfBlocks which each hold onto a transformed and filtered (collect, if) collection of results.
final class	CollectProcedureCombiner<T,V>	Combines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.
final class	CountCombiner<T>	Combines the results of a Collection of CountBlocks which each hold onto a filtered sum (count where) result.
final class	FastListCollectIfProcedureCombiner<T,V>	Combines the results of a Collection of FastListCollectIfProcedures which each hold onto a transformed and filtered (collect, if) collection of results.
final class	FastListCollectProcedureCombiner<T,V>	Combines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.
final class	FastListRejectProcedureCombiner<T>	Combines the results of a Collection of FastListRejectProcedures which each hold onto a negative filtered (reject) collection of results.
final class	FastListSelectProcedureCombiner<T>	Combines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.
final class	FlatCollectProcedureCombiner<T,V>	Combines the results of a Collection of FlatCollectProcedures which each hold onto a transformed (flatten) collection of results.
private static final class	ParallelIterate.SumByBigDecimalCombiner<T,V>
private static final class	ParallelIterate.SumByBigIntegerCombiner<T,V>
private static final class	ParallelIterate.SumByDoubleCombiner<T,V>
private static final class	ParallelIterate.SumByFloatCombiner<T,V>
private static final class	ParallelIterate.SumByIntCombiner<T,V>
private static final class	ParallelIterate.SumByLongCombiner<T,V>
final class	PassThruCombiner<T>	A PassThruCombiner doesn't do anything.
final class	RejectProcedureCombiner<T>	Combines the results of a Collection of SelectBlocks which each hold onto a negative filtered (reject) collection of results.
final class	SelectProcedureCombiner<T>	Combines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.

Fields in org.eclipse.collections.impl.parallel declared as Combiner

Modifier and Type	Field	Description
private final Combiner<BT>	ArrayProcedureFJTaskRunner.combiner
private final Combiner<BT>	BatchIterableProcedureFJTaskRunner.combiner
private final Combiner<BT>	ObjectIntProcedureFJTaskRunner.combiner
private final Combiner<BT>	ProcedureFJTaskRunner.combiner

Methods in org.eclipse.collections.impl.parallel that return Combiner

Modifier and Type	Method	Description
static <T> Combiner<T>	Combiners.passThru()

Methods in org.eclipse.collections.impl.parallel with parameters of type Combiner

Modifier and Type	Method	Description
private static <BT> CountDownLatch	ObjectIntProcedureFJTaskRunner.buildCountDownLatch(Combiner<BT> newCombiner, int taskCount)
private static <BT> ArrayBlockingQueue<BT>	ObjectIntProcedureFJTaskRunner.buildQueue(Combiner<BT> newCombiner, int taskCount)
private static <T, BT extends Procedure<? super T>> void	ParallelArrayIterate.combineSingleProcedure(Combiner<BT> combiner, BT procedure)
static <T, BT extends Procedure<? super T>> void	ParallelArrayIterate.forEach(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T, BT extends Procedure<? super T>> void	ParallelArrayIterate.forEach(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount)
static <T, BT extends Procedure<? super T>> void	ParallelIterate.forEach(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T, BT extends Procedure<? super T>> void	ParallelIterate.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>> void	ParallelIterate.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>> void	ParallelIterate.forEach(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends Procedure<? super T>> void	ParallelIterate.forEach(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int batchSize, Executor executor)
static <T, BT extends Procedure<? super T>> void	ParallelIterate.forEach(Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, Executor executor)
static <T, BT extends Procedure<? super T>> void	ParallelIterate.forEachInBatchWithExecutor(BatchIterable<T> set, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends Procedure<? super T>> void	ParallelIterate.forEachInListOnExecutor(List<T> list, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends Procedure<? super T>> void	ParallelArrayIterate.forEachOn(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndex(Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount)
static <T, BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndex(Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, Executor executor)
static <T, BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndex(Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, Executor executor)
static <T, BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.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 Combiner

Modifier	Constructor	Description
	ArrayProcedureFJTaskRunner(Combiner<BT> newCombiner, int newTaskCount)
	BatchIterableProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)
	ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)
(package private)	ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount, BlockingQueue<BT> queue, CountDownLatch latch)
	ProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)