akka.util

Class StablePriorityQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

akka.util.StablePriorityQueue<E>

All Implemented Interfaces:

PriorityQueueStabilizer<E>, java.lang.Iterable<E>, java.util.Collection<E>, java.util.Queue<E>

public class StablePriorityQueue<E>
extends java.util.AbstractQueue<E>
implements PriorityQueueStabilizer<E>

StablePriorityQueue is a priority queue that preserves order for elements of equal priority. param: capacity - the initial capacity of this Queue, needs to be &gt; 0. param: cmp - Comparator for comparing Queue elements

Nested Class Summary

Nested classes/interfaces inherited from interface akka.util.PriorityQueueStabilizer

PriorityQueueStabilizer.WrappedElement<E>, PriorityQueueStabilizer.WrappedElementComparator<E>

Constructor Summary

Constructors

Constructor and Description
StablePriorityQueue(int capacity, java.util.Comparator<E> cmp)

Method Summary

Modifier and Type	Method and Description
java.util.PriorityQueue<PriorityQueueStabilizer.WrappedElement<E>>	backingQueue()
java.util.concurrent.atomic.AtomicLong	seqNum()

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.util.PriorityQueueStabilizer

iterator, offer, peek, poll, size

Methods inherited from interface java.util.Queue

offer, peek, poll

Methods inherited from interface java.util.Collection

contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

StablePriorityQueue

public StablePriorityQueue(int capacity,
                           java.util.Comparator<E> cmp)

Method Detail

seqNum

public java.util.concurrent.atomic.AtomicLong seqNum()

Specified by:

seqNum in interface PriorityQueueStabilizer<E>

backingQueue

public java.util.PriorityQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()

Specified by:

backingQueue in interface PriorityQueueStabilizer<E>