org.openimaj.util.parallel.partition

Class RangePartitioner<T>

java.lang.Object

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

Type Parameters:

T - Type of object in the partition

All Implemented Interfaces:

Partitioner<T>

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

A RangePartitioner partitions data of a known size into a predefined number of equally sized partitions. If the time taken for processing each partition with Operations varies, then this partitioner is not load-balancing (so threads may end up waiting whilst others are still working).

Author:

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

Constructor Summary

Constructors

Constructor and Description
RangePartitioner(Collection<T> c) Construct with a Collection of data and the number of partitions equal to the number of hardware threads.
RangePartitioner(Collection<T> c, int numPartitions) Construct with a Collection of data and the given number of partitions.
RangePartitioner(List<T> list) Construct with a List of data and the number of partitions equal to the number of hardware threads.
RangePartitioner(List<T> list, int numPartitions) Construct with a List of data and the given number of partitions.
RangePartitioner(T[] array) Construct with an array of data and the number of partitions equal to the number of hardware threads.
RangePartitioner(T[] array, int numPartitions) Construct with an array of data and the given number of partitions.

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

RangePartitioner

public RangePartitioner(List<T> list,
                        int numPartitions)

Construct with a List of data and the given number of partitions.

Parameters:

list - the data

numPartitions - the number of partitions

RangePartitioner

public RangePartitioner(Collection<T> c,
                        int numPartitions)

Construct with a Collection of data and the given number of partitions.

Parameters:

c - the data

numPartitions - the number of partitions

RangePartitioner

public RangePartitioner(T[] array,
                        int numPartitions)

Construct with an array of data and the given number of partitions.

Parameters:

array - the data

numPartitions - the number of partitions

RangePartitioner

public RangePartitioner(List<T> list)

Construct with a List of data and the number of partitions equal to the number of hardware threads.

Parameters:

list - the data

RangePartitioner

public RangePartitioner(Collection<T> c)

Construct with a Collection of data and the number of partitions equal to the number of hardware threads.

Parameters:

c - the data

RangePartitioner

public RangePartitioner(T[] array)

Construct with an array of data and the number of partitions equal to the number of hardware threads.

Parameters:

array - the data

Method Detail

getPartitions

public Iterator<Iterator<T>> getPartitions()

Specified by:

getPartitions in interface Partitioner<T>

Returns:

the partitioned data.