Package | Description |
---|---|
org.jctools.queues.atomic |
Modifier and Type | Field and Description |
---|---|
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueConsumerNodeRef.consumerNode |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueProducerNodeRef.producerNode |
Modifier and Type | Field and Description |
---|---|
private static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<BaseLinkedAtomicQueueConsumerNodeRef,LinkedQueueAtomicNode> |
BaseLinkedAtomicQueueConsumerNodeRef.C_NODE_UPDATER |
private static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<BaseLinkedAtomicQueueProducerNodeRef,LinkedQueueAtomicNode> |
BaseLinkedAtomicQueueProducerNodeRef.P_NODE_UPDATER |
Modifier and Type | Method and Description |
---|---|
private LinkedQueueAtomicNode<E> |
MpscLinkedAtomicQueue.getNextConsumerNode(LinkedQueueAtomicNode<E> currConsumerNode) |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueConsumerNodeRef.lpConsumerNode() |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueProducerNodeRef.lpProducerNode() |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueConsumerNodeRef.lvConsumerNode() |
LinkedQueueAtomicNode<E> |
LinkedQueueAtomicNode.lvNext() |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueProducerNodeRef.lvProducerNode() |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueue.newNode() |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueue.newNode(E e) |
private LinkedQueueAtomicNode<E> |
MpscLinkedAtomicQueue.spinWaitForNextNode(LinkedQueueAtomicNode<E> currNode) |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueProducerNodeRef.xchgProducerNode(LinkedQueueAtomicNode<E> newValue) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
BaseLinkedAtomicQueueProducerNodeRef.casProducerNode(LinkedQueueAtomicNode<E> expect,
LinkedQueueAtomicNode<E> newValue) |
protected boolean |
BaseLinkedAtomicQueueProducerNodeRef.casProducerNode(LinkedQueueAtomicNode<E> expect,
LinkedQueueAtomicNode<E> newValue) |
private LinkedQueueAtomicNode<E> |
MpscLinkedAtomicQueue.getNextConsumerNode(LinkedQueueAtomicNode<E> currConsumerNode) |
protected E |
BaseLinkedAtomicQueue.getSingleConsumerNodeValue(LinkedQueueAtomicNode<E> currConsumerNode,
LinkedQueueAtomicNode<E> nextNode) |
protected E |
BaseLinkedAtomicQueue.getSingleConsumerNodeValue(LinkedQueueAtomicNode<E> currConsumerNode,
LinkedQueueAtomicNode<E> nextNode) |
void |
LinkedQueueAtomicNode.soNext(LinkedQueueAtomicNode<E> n) |
protected void |
BaseLinkedAtomicQueueConsumerNodeRef.spConsumerNode(LinkedQueueAtomicNode<E> newValue) |
private LinkedQueueAtomicNode<E> |
MpscLinkedAtomicQueue.spinWaitForNextNode(LinkedQueueAtomicNode<E> currNode) |
protected void |
BaseLinkedAtomicQueueProducerNodeRef.spProducerNode(LinkedQueueAtomicNode<E> newValue) |
protected LinkedQueueAtomicNode<E> |
BaseLinkedAtomicQueueProducerNodeRef.xchgProducerNode(LinkedQueueAtomicNode<E> newValue) |