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 |
private LinkedQueueAtomicNode<E> |
consumerNode |
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, b170, b171, b172, b173, b174, b175, b176, b177
UNBOUNDED_CAPACITY
Constructor and Description |
---|
BaseLinkedAtomicQueueConsumerNodeRef() |
Modifier and Type | Method and Description |
---|---|
(package private) LinkedQueueAtomicNode<E> |
lpConsumerNode() |
(package private) LinkedQueueAtomicNode<E> |
lvConsumerNode() |
(package private) void |
spConsumerNode(LinkedQueueAtomicNode<E> newValue) |
casProducerNode, lpProducerNode, lvProducerNode, soProducerNode, 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
private volatile LinkedQueueAtomicNode<E> consumerNode
final void spConsumerNode(LinkedQueueAtomicNode<E> newValue)
final LinkedQueueAtomicNode<E> lvConsumerNode()
final LinkedQueueAtomicNode<E> lpConsumerNode()