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 |
---|---|---|
void |
FJBatchIterableProcedureRunner.executeAndCombine(java.util.concurrent.ForkJoinPool executor,
ProcedureFactory<PT> procedureFactory,
BatchIterable<T> list) |
|
void |
FJListProcedureRunner.executeAndCombine(java.util.concurrent.ForkJoinPool executor,
ProcedureFactory<PT> procedureFactory,
java.util.List<T> list) |
|
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) |
Constructor | 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,
java.util.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 | 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 | Description |
---|---|---|
void |
ArrayProcedureFJTaskRunner.executeAndCombine(java.util.concurrent.Executor executor,
ProcedureFactory<BT> procedureFactory,
T[] array) |
|
void |
BatchIterableProcedureFJTaskRunner.executeAndCombine(java.util.concurrent.Executor executor,
ProcedureFactory<BT> procedureFactory,
BatchIterable<T> set) |
|
void |
ProcedureFJTaskRunner.executeAndCombine(java.util.concurrent.Executor executor,
ProcedureFactory<BT> procedureFactory,
java.util.List<T> list) |
|
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) |
Constructor | 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,
java.util.List<T> list,
int index,
int sectionSize,
boolean isLast) |
Creates an array of ProcedureFJTasks wrapping Procedures created by the specified ProcedureFactory.
|
Copyright © 2004–2018. All rights reserved.