LimitedQueue

public class LimitedQueue<ElementType> implements BlockingQueue<ElementType>

A limited capacity BlockingQueue which overrides add in order to remove the oldest element when the size limit is reached.

Author

jwienke

Parameters

<ElementType> – contained element type

Constructors

LimitedQueue

public LimitedQueue(int capacity)

Creates a queue with the specified capacity. Oldest elements are removed on add in case the capacity limit is reached.

Parameters

capacity – capacity of the queue

Methods

add

public boolean add(ElementType e)

addAll

public boolean addAll(Collection<? extends ElementType> c)

clear

public void clear()

contains

public boolean contains(Object o)

containsAll

public boolean containsAll(Collection<?> c)

drainTo

public int drainTo(Collection<? super ElementType> c)

drainTo

public int drainTo(Collection<? super ElementType> c, int maxElements)

element

public ElementType element()

getQueue

protected BlockingQueue<ElementType> getQueue()

Returns the underlying queue.

Returns

queue instance

isEmpty

public boolean isEmpty()

iterator

public Iterator<ElementType> iterator()

offer

public boolean offer(ElementType e)

offer

public boolean offer(ElementType e, long timeout, TimeUnit unit)

peek

public ElementType peek()

poll

public ElementType poll()

poll

public ElementType poll(long timeout, TimeUnit unit)

put

public void put(ElementType e)

remainingCapacity

public int remainingCapacity()

remove

public ElementType remove()

remove

public boolean remove(Object o)

removeAll

public boolean removeAll(Collection<?> c)

retainAll

public boolean retainAll(Collection<?> c)

size

public int size()

take

public ElementType take()

toArray

public Object[] toArray()

toArray

public <TargetType> TargetType[] toArray(TargetType[] a)