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>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner)
static <T,PT extends Procedure<? super T>>
voidFJIterate. 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>>
voidFJIterate. 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>>
voidFJIterate. 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>>
voidFJIterate. 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>>
voidFJIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends Procedure<? super T>>
voidFJIterate. 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>>
voidFJIterate. 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>>
voidFJIterate. forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, int minForkSize, int taskCount)
static <T,PT extends ObjectIntProcedure<? super T>>
voidFJIterate. 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>>
voidFJIterate. forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<PT> procedureFactory, Combiner<PT> combiner, java.util.concurrent.ForkJoinPool executor)
static <T,PT extends ObjectIntProcedure<? super T>>
voidFJIterate. 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 ofFlatCollectProcedure
s 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>>
voidParallelArrayIterate. combineSingleProcedure(Combiner<BT> combiner, BT procedure)
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(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. 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>>
voidParallelIterate. 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>>
voidParallelIterate. 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>>
voidParallelIterate. 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>>
voidParallelIterate. forEach(java.lang.Iterable<T> iterable, ProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, java.util.concurrent.Executor executor)
static <T,BT extends Procedure<? super T>>
voidParallelIterate. 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>>
voidParallelIterate. 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>>
voidParallelArrayIterate. 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>>
voidParallelIterate. forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, int minForkSize, int taskCount)
static <T,BT extends ObjectIntProcedure<? super T>>
voidParallelIterate. 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>>
voidParallelIterate. forEachWithIndex(java.lang.Iterable<T> iterable, ObjectIntProcedureFactory<BT> procedureFactory, Combiner<BT> combiner, java.util.concurrent.Executor executor)
static <T,BT extends ObjectIntProcedure<? super T>>
voidParallelIterate. 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)
-