org.apache.activemq.artemis.utils.collections

Class PriorityLinkedListImpl<T>

java.lang.Object

org.apache.activemq.artemis.utils.collections.PriorityLinkedListImpl<T>

All Implemented Interfaces:

PriorityLinkedList<T>

public class PriorityLinkedListImpl<T>
extends Object
implements PriorityLinkedList<T>

A priority linked list implementation

It implements this by maintaining an individual LinkedBlockingDeque for each priority level.

Field Summary

Fields

Modifier and Type	Field and Description
protected LinkedListImpl<T>[]	levels

Constructor Summary

Constructors

Constructor and Description
PriorityLinkedListImpl(int priorities)

Method Summary

Modifier and Type	Method and Description
void	addHead(T t, int priority)
void	addTail(T t, int priority)
void	clear()
boolean	isEmpty() Returns true if empty, false otherwise. It is safe to be called concurrently.
LinkedListIterator<T>	iterator()
T	poll()
int	size() Returns the size of this list. It is safe to be called concurrently.

Methods inherited from class java.lang.Object

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

Field Detail

levels

protected LinkedListImpl<T>[] levels

Constructor Detail

PriorityLinkedListImpl

public PriorityLinkedListImpl(int priorities)

Method Detail

addHead

public void addHead(T t,
                    int priority)

Specified by:

addHead in interface PriorityLinkedList<T>

addTail

public void addTail(T t,
                    int priority)

Specified by:

addTail in interface PriorityLinkedList<T>

poll

public T poll()

Specified by:

poll in interface PriorityLinkedList<T>

clear

public void clear()

Specified by:

clear in interface PriorityLinkedList<T>

size

public int size()

Description copied from interface: PriorityLinkedList

Returns the size of this list.
It is safe to be called concurrently.

Specified by:

size in interface PriorityLinkedList<T>

isEmpty

public boolean isEmpty()

Description copied from interface: PriorityLinkedList

Returns true if empty, false otherwise.
It is safe to be called concurrently.

Specified by:

isEmpty in interface PriorityLinkedList<T>

iterator

public LinkedListIterator<T> iterator()

Specified by:

iterator in interface PriorityLinkedList<T>