Package org.apache.pekko.util
Interface PriorityQueueStabilizer<E>
-
- All Known Implementing Classes:
StablePriorityBlockingQueue
,StablePriorityQueue
,UnboundedStablePriorityMailbox.MessageQueue
public interface PriorityQueueStabilizer<E>
PriorityQueueStabilizer wraps a priority queue so that it respects FIFO for elements of equal priority.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
PriorityQueueStabilizer.WrappedElement<E>
static class
PriorityQueueStabilizer.WrappedElementComparator<E>
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.AbstractQueue<PriorityQueueStabilizer.WrappedElement<E>>
backingQueue()
java.util.Iterator<E>
iterator()
boolean
offer(E e)
void
org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)
E
peek()
E
poll()
java.util.concurrent.atomic.AtomicLong
seqNum()
int
size()
-
-
-
Method Detail
-
org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq
void org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(java.util.concurrent.atomic.AtomicLong x$1)
-
backingQueue
java.util.AbstractQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()
-
seqNum
java.util.concurrent.atomic.AtomicLong seqNum()
-
peek
E peek()
-
size
int size()
-
offer
boolean offer(E e)
-
iterator
java.util.Iterator<E> iterator()
-
poll
E poll()
-
-