Package | Description |
---|---|
org.openimaj.util.parallel | |
org.openimaj.util.parallel.partition |
Modifier and Type | Method and Description |
---|---|
static <T> void |
Parallel.forEach(Partitioner<T> partitioner,
Operation<T> op)
Parallel ForEach loop over partitioned data.
|
static <T> void |
Parallel.forEach(Partitioner<T> partitioner,
Operation<T> op,
ThreadPoolExecutor pool)
Parallel ForEach loop over partitioned data.
|
static <T> void |
Parallel.forEachPartitioned(Partitioner<T> partitioner,
Operation<Iterator<T>> op)
Parallel ForEach loop over batched partitioned data.
|
static <T> void |
Parallel.forEachPartitioned(Partitioner<T> partitioner,
Operation<Iterator<T>> op,
ThreadPoolExecutor pool)
Parallel ForEach loop over partitioned data with batches of data.
|
Modifier and Type | Class and Description |
---|---|
class |
FixedSizeBlockingChunkPartitioner<T>
A
FixedSizeBlockingChunkPartitioner dynamically partitions data into
chunks of a fixed length. |
class |
FixedSizeChunkPartitioner<T>
A
FixedSizeChunkPartitioner dynamically partitions data into chunks
of a fixed length. |
class |
GrowingChunkPartitioner<T>
A
GrowingChunkPartitioner dynamically partitions data into chunks. |
class |
RangePartitioner<T>
A
RangePartitioner partitions data of a known size into a predefined
number of equally sized partitions. |