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 |
private LinkedQueueAtomicNode<E> |
producerNode |
b000, b001, b002, b003, b004, b005, b006, b007, b010, b011, b012, b013, b014, b015, b016, b017, b020, b021, b022, b023, b024, b025, b026, b027, b030, b031, b032, b033, b034, b035, b036, b037, b040, b041, b042, b043, b044, b045, b046, b047, b050, b051, b052, b053, b054, b055, b056, b057, b060, b061, b062, b063, b064, b065, b066, b067, b070, b071, b072, b073, b074, b075, b076, b077, b100, b101, b102, b103, b104, b105, b106, b107, b110, b111, b112, b113, b114, b115, b116, b117, b120, b121, b122, b123, b124, b125, b126, b127, b130, b131, b132, b133, b134, b135, b136, b137, b140, b141, b142, b143, b144, b145, b146, b147, b150, b151, b152, b153, b154, b155, b156, b157, b160, b161, b162, b163, b164, b165, b166, b167
UNBOUNDED_CAPACITY
Constructor and Description |
---|
BaseLinkedAtomicQueueProducerNodeRef() |
Modifier and Type | Method and Description |
---|---|
(package private) boolean |
casProducerNode(LinkedQueueAtomicNode<E> expect,
LinkedQueueAtomicNode<E> newValue) |
(package private) LinkedQueueAtomicNode<E> |
lpProducerNode() |
(package private) LinkedQueueAtomicNode<E> |
lvProducerNode() |
(package private) void |
soProducerNode(LinkedQueueAtomicNode<E> newValue) |
(package private) 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
private volatile LinkedQueueAtomicNode<E> producerNode
final void spProducerNode(LinkedQueueAtomicNode<E> newValue)
final void soProducerNode(LinkedQueueAtomicNode<E> newValue)
final LinkedQueueAtomicNode<E> lvProducerNode()
final boolean casProducerNode(LinkedQueueAtomicNode<E> expect, LinkedQueueAtomicNode<E> newValue)
final LinkedQueueAtomicNode<E> lpProducerNode()
protected final LinkedQueueAtomicNode<E> xchgProducerNode(LinkedQueueAtomicNode<E> newValue)