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.
|
Modifier and Type | Method | Description |
---|---|---|
static <T,PT extends Procedure<? super T>> |
FJIterate.forEach(java.lang.Iterable<T> iterable,
ProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner) |
|
static <T,PT extends Procedure<? super T>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
FJIterate.forEachWithIndex(java.lang.Iterable<T> iterable,
ObjectIntProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount) |
|
static <T,PT extends ObjectIntProcedure<? super T>> |
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>> |
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>> |
FJIterate.forEachWithIndexInListOnExecutor(java.util.List<T> list,
ObjectIntProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount,
java.util.concurrent.ForkJoinPool executor) |
Constructor | Description |
---|---|
FJBatchIterableProcedureRunner(Combiner<PT> newCombiner,
int taskCount) |
|
FJListObjectIntProcedureRunner(Combiner<PT> newCombiner,
int taskCount) |
|
FJListProcedureRunner(Combiner<PT> newCombiner,
int taskCount) |
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
FlatCollectProcedure s which each hold onto a transformed (flatten) collection
of results. |
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.
|
Modifier and Type | Method | Description |
---|---|---|
static <T> Combiner<T> |
Combiners.passThru() |
Modifier and Type | Method | Description |
---|---|---|
static <T,BT extends Procedure<? super T>> |
ParallelArrayIterate.forEach(T[] array,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner) |
|
static <T,BT extends Procedure<? super T>> |
ParallelArrayIterate.forEach(T[] array,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount) |
|
static <T,BT extends Procedure<? super T>> |
ParallelIterate.forEach(java.lang.Iterable<T> iterable,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner) |
|
static <T,BT extends Procedure<? super T>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
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>> |
ParallelIterate.forEachWithIndex(java.lang.Iterable<T> iterable,
ObjectIntProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount) |
|
static <T,BT extends ObjectIntProcedure<? super T>> |
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>> |
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>> |
ParallelIterate.forEachWithIndexInListOnExecutor(java.util.List<T> list,
ObjectIntProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
java.util.concurrent.Executor executor) |
Constructor | Description |
---|---|
ArrayProcedureFJTaskRunner(Combiner<BT> newCombiner,
int newTaskCount) |
|
BatchIterableProcedureFJTaskRunner(Combiner<BT> newCombiner,
int taskCount) |
|
ObjectIntProcedureFJTaskRunner(Combiner<BT> newCombiner,
int taskCount) |
|
ProcedureFJTaskRunner(Combiner<BT> newCombiner,
int taskCount) |
Copyright © 2004–2018. All rights reserved.