public class MpscIntrusiveLinkedQueue extends Object
Constructor and Description |
---|
MpscIntrusiveLinkedQueue() |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
boolean |
isEmpty() |
protected Node |
lpConsumerNode() |
protected Node |
lvConsumerNode() |
protected Node |
lvProducerNode() |
boolean |
offer(Node node) |
Node |
peek() |
Node |
poll() |
int |
size()
This is an O(n) operation as we run through all the nodes and count them.
The accuracy of the value returned by this method is subject to races with producer/consumer threads. |
protected void |
spConsumerNode(Node node) |
protected Node |
xchgProducerNode(Node node) |
protected final Node stub
public boolean offer(Node node)
public Node poll()
public Node peek()
public void clear()
public int size()
public boolean isEmpty()
protected final void spConsumerNode(Node node)
protected final Node lvConsumerNode()
protected final Node lpConsumerNode()
protected final Node lvProducerNode()
Copyright © 2013–2019. All rights reserved.