Package org.apache.activemq.artemis.utils.collections

Class PriorityLinkedListImpl<E>

java.lang.Object

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

All Implemented Interfaces:

PriorityLinkedList<E>

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

A priority linked list implementation

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
PriorityLinkedListImpl(int priorities)
PriorityLinkedListImpl(int priorities, Comparator<E> comparator)

Method Summary

Modifier and Type	Method	Description
void	addHead(E e, int priority)
void	addSorted(E e, int priority)
void	addTail(E e, int priority)
void	clear()
boolean	isEmpty()	Returns true if empty, false otherwise; safe to be called concurrently.
LinkedListIterator<E>	iterator()
E	peek()	just look at the first element on the list
E	poll()
protected void	removed(int level, E element)
E	removeWithID(String listID, long id)
void	setNodeStore(Supplier<NodeStore<E>> supplier)
int	size()	Returns the size of this list; safe to be called concurrently.

Methods inherited from class java.lang.Object

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

Field Details

levels

protected final LinkedListImpl<E>[] levels

Constructor Details

PriorityLinkedListImpl

public PriorityLinkedListImpl(int priorities)

PriorityLinkedListImpl

public PriorityLinkedListImpl(int priorities,
 Comparator<E> comparator)

Method Details

removed

protected void removed(int level,
 E element)

addHead

public void addHead(E e,
 int priority)

Specified by:

addHead in interface PriorityLinkedList<E>

addTail

public void addTail(E e,
 int priority)

Specified by:

addTail in interface PriorityLinkedList<E>

addSorted

public void addSorted(E e,
 int priority)

Specified by:

addSorted in interface PriorityLinkedList<E>

setNodeStore

public void setNodeStore(Supplier<NodeStore<E>> supplier)

Specified by:

setNodeStore in interface PriorityLinkedList<E>

See Also:

• LinkedList.setNodeStore(NodeStore)

removeWithID

public E removeWithID(String listID,
 long id)

Specified by:

removeWithID in interface PriorityLinkedList<E>

peek

public E peek()

Description copied from interface: PriorityLinkedList

just look at the first element on the list

Specified by:

peek in interface PriorityLinkedList<E>

poll

public E poll()

Specified by:

poll in interface PriorityLinkedList<E>

clear

public void clear()

Specified by:

clear in interface PriorityLinkedList<E>

size

public int size()

Description copied from interface: PriorityLinkedList

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

Specified by:

size in interface PriorityLinkedList<E>

Returns:

the size of this list; safe to be called concurrently

isEmpty

public boolean isEmpty()

Description copied from interface: PriorityLinkedList

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

Specified by:

isEmpty in interface PriorityLinkedList<E>

Returns:

true if empty, false otherwise; safe to be called concurrently

iterator

public LinkedListIterator<E> iterator()

Specified by:

iterator in interface PriorityLinkedList<E>