abstract class BaseLinkedAtomicQueueConsumerNodeRef<E> extends BaseLinkedAtomicQueuePad1<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<BaseLinkedAtomicQueueConsumerNodeRef,LinkedQueueAtomicNode> |
C_NODE_UPDATER |
protected LinkedQueueAtomicNode<E> |
consumerNode |
p01, p02, p03, p04, p05, p06, p07, p10, p11, p12, p13, p14, p15, p16, p17
producerNode
p00
UNBOUNDED_CAPACITY
Constructor and Description |
---|
BaseLinkedAtomicQueueConsumerNodeRef() |
Modifier and Type | Method and Description |
---|---|
protected LinkedQueueAtomicNode<E> |
lpConsumerNode() |
protected LinkedQueueAtomicNode<E> |
lvConsumerNode() |
protected void |
spConsumerNode(LinkedQueueAtomicNode<E> newValue) |
casProducerNode, lpProducerNode, lvProducerNode, spProducerNode, xchgProducerNode
contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
capacity, clear, drain, drain, drain, fill, fill, fill, isEmpty, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<BaseLinkedAtomicQueueConsumerNodeRef,LinkedQueueAtomicNode> C_NODE_UPDATER
protected volatile LinkedQueueAtomicNode<E> consumerNode
protected final void spConsumerNode(LinkedQueueAtomicNode<E> newValue)
protected final LinkedQueueAtomicNode<E> lvConsumerNode()
protected final LinkedQueueAtomicNode<E> lpConsumerNode()