abstract class BaseLinkedAtomicQueueProducerNodeRef<E> extends BaseLinkedAtomicQueuePad0<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<BaseLinkedAtomicQueueProducerNodeRef,LinkedQueueAtomicNode> |
P_NODE_UPDATER |
protected LinkedQueueAtomicNode<E> |
producerNode |
p00, p01, p02, p03, p04, p05, p06, p07, p10, p11, p12, p13, p14, p15, p16
UNBOUNDED_CAPACITY
Constructor and Description |
---|
BaseLinkedAtomicQueueProducerNodeRef() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
casProducerNode(LinkedQueueAtomicNode<E> expect,
LinkedQueueAtomicNode<E> newValue) |
protected LinkedQueueAtomicNode<E> |
lpProducerNode() |
protected LinkedQueueAtomicNode<E> |
lvProducerNode() |
protected void |
spProducerNode(LinkedQueueAtomicNode<E> newValue) |
protected LinkedQueueAtomicNode<E> |
xchgProducerNode(LinkedQueueAtomicNode<E> newValue) |
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<BaseLinkedAtomicQueueProducerNodeRef,LinkedQueueAtomicNode> P_NODE_UPDATER
protected volatile LinkedQueueAtomicNode<E> producerNode
protected final void spProducerNode(LinkedQueueAtomicNode<E> newValue)
protected final LinkedQueueAtomicNode<E> lvProducerNode()
protected final boolean casProducerNode(LinkedQueueAtomicNode<E> expect, LinkedQueueAtomicNode<E> newValue)
protected final LinkedQueueAtomicNode<E> lpProducerNode()
protected final LinkedQueueAtomicNode<E> xchgProducerNode(LinkedQueueAtomicNode<E> newValue)