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 |
FJListObjectIntProcedureRunner.executeAndCombine(ForkJoinPool executor,
ObjectIntProcedureFactory<PT> procedureFactory,
List<T> list) |
static <T,PT extends ObjectIntProcedure<? super T>> |
FJIterate.forEachWithIndex(Iterable<T> iterable,
ObjectIntProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
ForkJoinPool executor) |
static <T,PT extends ObjectIntProcedure<? super T>> |
FJIterate.forEachWithIndex(Iterable<T> iterable,
ObjectIntProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount) |
static <T,PT extends ObjectIntProcedure<? super T>> |
FJIterate.forEachWithIndex(Iterable<T> iterable,
ObjectIntProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount,
ForkJoinPool executor) |
static <T,PT extends ObjectIntProcedure<? super T>> |
FJIterate.forEachWithIndexInListOnExecutor(List<T> list,
ObjectIntProcedureFactory<PT> procedureFactory,
Combiner<PT> combiner,
int minForkSize,
int taskCount,
ForkJoinPool executor) |
Constructor and Description |
---|
FJListObjectIntProcedureTask(FJListObjectIntProcedureRunner<T,PT> newFJTaskRunner,
ObjectIntProcedureFactory<PT> newBlockFactory,
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 and 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 and Description |
---|---|
void |
ObjectIntProcedureFJTaskRunner.executeAndCombine(Executor executor,
ObjectIntProcedureFactory<BT> procedureFactory,
List<T> list) |
static <T,BT extends ObjectIntProcedure<? super T>> |
ParallelIterate.forEachWithIndex(Iterable<T> iterable,
ObjectIntProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
Executor executor) |
static <T,BT extends ObjectIntProcedure<? super T>> |
ParallelIterate.forEachWithIndex(Iterable<T> iterable,
ObjectIntProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount) |
static <T,BT extends ObjectIntProcedure<? super T>> |
ParallelIterate.forEachWithIndex(Iterable<T> iterable,
ObjectIntProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
Executor executor) |
static <T,BT extends ObjectIntProcedure<? super T>> |
ParallelIterate.forEachWithIndexInListOnExecutor(List<T> list,
ObjectIntProcedureFactory<BT> procedureFactory,
Combiner<BT> combiner,
int minForkSize,
int taskCount,
Executor executor) |
Constructor and Description |
---|
ObjectIntProcedureFJTask(ObjectIntProcedureFJTaskRunner<T,BT> newFJTaskRunner,
ObjectIntProcedureFactory<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.