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 Combiner<PT>	FJBatchIterableProcedureRunner.combiner
private Combiner<PT>	FJListObjectIntProcedureRunner.combiner
private 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(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner)
static <T,PT extends Procedure<? super T>> void	FJIterate.forEach(java.lang.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(java.lang.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(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>> void	FJIterate.forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> blockFactory, Combiner<PT> combiner, int batchSize, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>> void	FJIterate.forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, java.util.concurrent.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, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>> void	FJIterate.forEachInListOnExecutor(java.util.List<T> list, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount)
static <T,PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends ObjectIntProcedure<? super T>> void	FJIterate.forEachWithIndexInListOnExecutor(java.util.List<T> list, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount, java.util.concurrent.ForkJoinPool executor)

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

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>>
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.
class	CollectProcedureCombiner<T,V>	Combines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.
class	CountCombiner<T>	Combines the results of a Collection of CountBlocks which each hold onto a filtered sum (count where) result.
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.
class	FastListCollectProcedureCombiner<T,V>	Combines the results of a Collection of CollectBlocks which each hold onto a transformed (collect) collection of results.
class	FastListRejectProcedureCombiner<T>	Combines the results of a Collection of FastListRejectProcedures which each hold onto a negative filtered (reject) collection of results.
class	FastListSelectProcedureCombiner<T>	Combines the results of a Collection of SelectBlocks which each hold onto a filtered (select) collection of results.
class	FlatCollectProcedureCombiner<T,V>	Combines the results of a Collection of FlatCollectProcedures which each hold onto a transformed (flatten) collection of results.
private static class	ParallelIterate.SumByBigDecimalCombiner<T,V>
private static class	ParallelIterate.SumByBigIntegerCombiner<T,V>
private static class	ParallelIterate.SumByDoubleCombiner<T,V>
private static class	ParallelIterate.SumByFloatCombiner<T,V>
private static class	ParallelIterate.SumByIntCombiner<T,V>
private static class	ParallelIterate.SumByLongCombiner<T,V>
class	PassThruCombiner<T>	A PassThruCombiner doesn't do anything.
class	RejectProcedureCombiner<T>	Combines the results of a Collection of SelectBlocks which each hold onto a negative filtered (reject) collection of results.
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 Combiner<BT>	ArrayProcedureFJTaskRunner.combiner
private Combiner<BT>	BatchIterableProcedureFJTaskRunner.combiner
private Combiner<BT>	ObjectIntProcedureFJTaskRunner.combiner
private 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> java.util.concurrent.CountDownLatch	ObjectIntProcedureFJTaskRunner.buildCountDownLatch(Combiner<BT> newCombiner, int taskCount)
private static <BT> java.util.concurrent.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(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T,BT extends Procedure<? super T>> void	ParallelIterate.forEach(java.lang.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(java.lang.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(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>> void	ParallelIterate.forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int batchSize, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>> void	ParallelIterate.forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, java.util.concurrent.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, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>> void	ParallelIterate.forEachInListOnExecutor(java.util.List<T> list, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>> void	ParallelArrayIterate.forEachOn(T[] array, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount)
static <T,BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)
static <T,BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, java.util.concurrent.Executor executor)
static <T,BT extends ObjectIntProcedure<? super T>> void	ParallelIterate.forEachWithIndexInListOnExecutor(java.util.List<T> list, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount, java.util.concurrent.Executor executor)

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

Constructor	Description
ArrayProcedureFJTaskRunner(Combiner<BT> newCombiner, int newTaskCount)
BatchIterableProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount, java.util.concurrent.BlockingQueue<BT> queue, java.util.concurrent.CountDownLatch latch)
ProcedureFJTaskRunner(Combiner<BT> newCombiner, int taskCount)