org.openimaj.util.parallel.partition

Class FixedSizeBlockingChunkPartitioner<T>

java.lang.Object

org.openimaj.util.parallel.partition.FixedSizeBlockingChunkPartitioner<T>

Type Parameters:

T - Type of object in the partition

All Implemented Interfaces:

Partitioner<T>

public class FixedSizeBlockingChunkPartitioner<T>
extends Object
implements Partitioner<T>

A FixedSizeBlockingChunkPartitioner dynamically partitions data into chunks of a fixed length. The partitioner does not need to know about the length of the data apriori. Beyond a FixedSizeChunkPartitioner this implementation doesn't use an underlying iterator. It can only be instantiated on queues and will always report to have more items available while it waits for the queue to be filled.

Author:

Jonathon Hare (jsh2@ecs.soton.ac.uk)

Constructor Summary

Constructors

Constructor and Description
FixedSizeBlockingChunkPartitioner(Queue<T> objects) Construct with data in the form of a Queue.
FixedSizeBlockingChunkPartitioner(Queue<T> objects, int chunkSize) Construct with data in the form of an Queue and the given number of items per chunk.

Method Summary

Modifier and Type	Method and Description
Iterator<Iterator<T>>	getPartitions()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedSizeBlockingChunkPartitioner

public FixedSizeBlockingChunkPartitioner(Queue<T> objects)

Construct with data in the form of a Queue. The number of items per chunk is set at the default value (20).

Parameters:

objects - the Queue representing the data.

FixedSizeBlockingChunkPartitioner

public FixedSizeBlockingChunkPartitioner(Queue<T> objects,
                                         int chunkSize)

Construct with data in the form of an Queue and the given number of items per chunk.

Parameters:

objects - the Queue representing the data.

chunkSize - number of items in each chunk.

Method Detail

getPartitions

public Iterator<Iterator<T>> getPartitions()

Specified by:

getPartitions in interface Partitioner<T>

Returns:

the partitioned data.