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

Modifier and Type	Method	Description
AbstractQueue<PriorityQueueStabilizer.WrappedElement<E>>	backingQueue()
Iterator<E>	iterator()
boolean	offer(E e)
void	org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(AtomicLong x$1)
E	peek()
E	poll()
AtomicLong	seqNum()
int	size()

Method Details

org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq

void org$apache$pekko$util$PriorityQueueStabilizer$_setter_$seqNum_$eq(AtomicLong x$1)

backingQueue

AbstractQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()

seqNum

AtomicLong seqNum()

peek

E peek()

size

int size()

offer

boolean offer(E e)

iterator

Iterator<E> iterator()

poll

E poll()