public class StablePriorityBlockingQueue<E> extends java.util.AbstractQueue<E> implements PriorityQueueStabilizer<E>
PriorityQueueStabilizer.WrappedElement<E>, PriorityQueueStabilizer.WrappedElementComparator<E>
Constructor and Description |
---|
StablePriorityBlockingQueue(int capacity,
java.util.Comparator<E> cmp) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.PriorityBlockingQueue<PriorityQueueStabilizer.WrappedElement<E>> |
backingQueue() |
java.util.concurrent.atomic.AtomicLong |
seqNum() |
contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
iterator, offer, peek, poll, size
public StablePriorityBlockingQueue(int capacity, java.util.Comparator<E> cmp)
public java.util.concurrent.atomic.AtomicLong seqNum()
seqNum
in interface PriorityQueueStabilizer<E>
public java.util.concurrent.PriorityBlockingQueue<PriorityQueueStabilizer.WrappedElement<E>> backingQueue()
backingQueue
in interface PriorityQueueStabilizer<E>