com.illumon.modelfarm.util

Class KeyedPriorityBlockingQueue<E>

java.lang.Object

com.illumon.modelfarm.util.KeyedPriorityBlockingQueue<E>

public class KeyedPriorityBlockingQueue<E>
extends Object

A priority blocking queue that maintains one element per key. If a later request comes in of higher priority, the lower priority item is replaced by the higher priority item. The element type must be usable in a hash map.

Constructor Summary

Constructors

Constructor and Description
KeyedPriorityBlockingQueue()

Method Summary

Modifier and Type	Method and Description
void	enqueue(E element, int priority) Add an element to the queue.
boolean	isEmpty() Returns true if the queue is empty; false otherwise.
E	take() Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyedPriorityBlockingQueue

public KeyedPriorityBlockingQueue()

Method Detail

enqueue

public void enqueue(E element,
                    int priority)

Add an element to the queue. If the element is already in the queue, the element's priority will be the higher of the existing element and the new element.

Parameters:

element - element to enqueue.

priority - priority of the element.

take

public E take()
       throws InterruptedException

Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.

Returns:

the head of this queue

Throws:

InterruptedException - if interrupted while waiting

isEmpty

public boolean isEmpty()

Returns true if the queue is empty; false otherwise.

Returns:

true if the queue is empty; false otherwise.