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 and Description |
---|---|
void |
FJBatchIterableProcedureRunner.executeAndCombine(ForkJoinPool executor,
ProcedureFactory<PT> procedureFactory,
BatchIterable<T> list) |
void |
FJListProcedureRunner.executeAndCombine(ForkJoinPool executor,
ProcedureFactory<PT> procedureFactory,
List<T> list) |
static <T,PT extends Procedure<? super T>> |
FJIterate.forEach(Iterable<T> iterable,
ProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner) |
static <T,PT extends Procedure<? super T>> |
FJIterate.forEach(Iterable<T> iterable,
ProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
ForkJoinPool executor) |
static <T,PT extends Procedure<? super T>> |
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>> |
FJIterate.forEach(Iterable<T> iterable,
ProcedureFactory<PT> blockFactory,
Combiner<PT> combiner,
int batchSize,
ForkJoinPool executor) |
static <T,PT extends Procedure<? super T>> |
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>> |
FJIterate.forEach(Iterable<T> iterable,
ProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount,
ForkJoinPool executor) |
static <T,PT extends Procedure<? super T>> |
FJIterate.forEachInBatchWithExecutor(BatchIterable<T> batchIterable,
ProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount,
ForkJoinPool executor) |
static <T,PT extends Procedure<? super T>> |
FJIterate.forEachInListOnExecutor(List<T> list,
ProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount,
ForkJoinPool executor) |
Constructor and Description |
---|
FJBatchIterableProcedureTask(FJBatchIterableProcedureRunner<T,PT> newFJTaskRunner,
ProcedureFactory<PT> newProcedureFactory,
BatchIterable<T> iterable,
int index,
int count)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
|
FJListProcedureTask(FJListProcedureRunner<T,PT> newFJTaskRunner,
ProcedureFactory<PT> newProcedureFactory,
List<T> list,
int index,
int sectionSize,
boolean isLast)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectIfProcedureFactory<T,V> |
class |
CollectProcedureFactory<T,V> |
class |
CountProcedureFactory<T> |
class |
FastListCollectIfProcedureFactory<T,V> |
class |
FastListCollectProcedureFactory<T,V> |
class |
FastListRejectProcedureFactory<T> |
class |
FastListSelectProcedureFactory<T> |
class |
FlatCollectProcedureFactory<T,V> |
class |
PassThruProcedureFactory<BT extends Procedure<?>> |
class |
RejectProcedureFactory<T> |
class |
SelectProcedureFactory<T> |
Modifier and Type | Method and Description |
---|---|
void |
BatchIterableProcedureFJTaskRunner.executeAndCombine(Executor executor,
ProcedureFactory<BT> procedureFactory,
BatchIterable<T> set) |
void |
ProcedureFJTaskRunner.executeAndCombine(Executor executor,
ProcedureFactory<BT> procedureFactory,
List<T> list) |
void |
ArrayProcedureFJTaskRunner.executeAndCombine(Executor executor,
ProcedureFactory<BT> procedureFactory,
T[] array) |
static <T,BT extends Procedure<? super T>> |
ParallelIterate.forEach(Iterable<T> iterable,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner) |
static <T,BT extends Procedure<? super T>> |
ParallelIterate.forEach(Iterable<T> iterable,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
Executor executor) |
static <T,BT extends Procedure<? super T>> |
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>> |
ParallelIterate.forEach(Iterable<T> iterable,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int batchSize,
Executor executor) |
static <T,BT extends Procedure<? super T>> |
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>> |
ParallelIterate.forEach(Iterable<T> iterable,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
Executor executor) |
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.forEachInBatchWithExecutor(BatchIterable<T> set,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
Executor executor) |
static <T,BT extends Procedure<? super T>> |
ParallelIterate.forEachInListOnExecutor(List<T> list,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
Executor executor) |
static <T,BT extends Procedure<? super T>> |
ParallelArrayIterate.forEachOn(T[] array,
ProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
Executor executor) |
Constructor and Description |
---|
ArrayProcedureFJTask(ArrayProcedureFJTaskRunner<T,BT> newFJTaskRunner,
ProcedureFactory<BT> procedureFactory,
T[] newArray,
int newIndex,
int newSectionSize,
boolean isLast) |
BatchIterableProcedureFJTask(BatchIterableProcedureFJTaskRunner<T,BT> newFJTaskRunner,
ProcedureFactory<BT> procedureFactory,
BatchIterable<T> iterable,
int index,
int count)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
|
ProcedureFJTask(ProcedureFJTaskRunner<T,BT> newFJTaskRunner,
ProcedureFactory<BT> newProcedureFactory,
List<T> list,
int index,
int sectionSize,
boolean isLast)
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
|
Copyright © 2004–2016. All rights reserved.