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 |
FJListObjectIntProcedureRunner.executeAndCombine(java.util.concurrent.ForkJoinPool executor,
ObjectIntProcedureFactory<PT> procedureFactory,
java.util.List<T> list) |
|
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 |
---|---|
FJListObjectIntProcedureTask(FJListObjectIntProcedureRunner<T,PT> newFJTaskRunner,
ObjectIntProcedureFactory<PT> newBlockFactory,
java.util.List<T> list,
int index,
int sectionSize,
boolean isLast) |
Creates an array of VoidBlockFJTasks wrapping VoidBlocks created by the specified VoidBlockFactory.
|
Modifier and Type | Class | Description |
---|---|---|
class |
PassThruObjectIntProcedureFactory<BT extends ObjectIntProcedure<?>> |
This class acts as a no op factory for a ObjectIntProcedure which gets passed in and returned out.
|
Modifier and Type | Method | Description |
---|---|---|
void |
ObjectIntProcedureFJTaskRunner.executeAndCombine(java.util.concurrent.Executor executor,
ObjectIntProcedureFactory<BT> procedureFactory,
java.util.List<T> list) |
|
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 |
---|---|
ObjectIntProcedureFJTask(ObjectIntProcedureFJTaskRunner<T,BT> newFJTaskRunner,
ObjectIntProcedureFactory<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.