Package 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 > 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 Description StablePriorityQueue(int capacity, java.util.Comparator<E> cmp)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)
java.util.PriorityQueue<PriorityQueueStabilizer.WrappedElement<E>>
backingQueue()
java.util.concurrent.atomic.AtomicLong
seqNum()
-
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 java.util.Collection
contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray
-
-
-
-
Constructor Detail
-
StablePriorityQueue
public StablePriorityQueue(int capacity, java.util.Comparator<E> cmp)
-
-
Method Detail
-
akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq
protected void akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)
- Specified by:
akka$util$PriorityQueueStabilizer$_setter_$seqNum_$eq
in interfacePriorityQueueStabilizer<E>
-
backingQueue
public java.util.PriorityQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()
- Specified by:
backingQueue
in interfacePriorityQueueStabilizer<E>
-
seqNum
public java.util.concurrent.atomic.AtomicLong seqNum()
- Specified by:
seqNum
in interfacePriorityQueueStabilizer<E>
-
-