org.apache.giraph.utils

Class BlockingElementsSet<T>

java.lang.Object

org.apache.giraph.utils.BlockingElementsSet<T>

Type Parameters:

T - Element type

public class BlockingElementsSet<T>
extends Object

Keeps a set of elements, and allows for waiting on certain number of elements to become available. Assumes that at any point no more elements than we'll be asking for will be added to the set. Reusable.

Constructor Summary

Constructors

Constructor and Description
BlockingElementsSet()

Method Summary

Modifier and Type	Method and Description
T	getElement(org.apache.hadoop.util.Progressable progressable) Get one element when it becomes available, reporting progress while waiting
List<T>	getElements(int elementCount, org.apache.hadoop.util.Progressable progressable) Get desired number of elements when they become available, reporting progress while waiting
void	offer(T element) Put an element in the set

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingElementsSet

public BlockingElementsSet()

Method Detail

offer

public void offer(T element)

Put an element in the set

Parameters:

element - Element to put

getElement

public T getElement(org.apache.hadoop.util.Progressable progressable)

Get one element when it becomes available, reporting progress while waiting

Parameters:

progressable - Progressable to report progress

Returns:

Element acquired

getElements

public List<T> getElements(int elementCount,
                           org.apache.hadoop.util.Progressable progressable)

Get desired number of elements when they become available, reporting progress while waiting

Parameters:

elementCount - How many elements to wait for

progressable - Progressable to report progress

Returns:

List of elements acquired