E
- public final class SpscLinkedAtomicQueue<E> extends BaseLinkedAtomicQueue<E>
Constructor and Description |
---|
SpscLinkedAtomicQueue() |
Modifier and Type | Method and Description |
---|---|
boolean |
offer(E e)
IMPLEMENTATION NOTES: Offer is allowed from a SINGLE thread. Offer allocates a new node (holding the offered value) and: Sets that node as the producerNode.next Sets the new node as the producerNode From this follows that producerNode.next is always null and for all other nodes node.next is not null. |
E |
peek() |
E |
poll()
IMPLEMENTATION NOTES: Poll is allowed from a SINGLE thread. Poll reads the next node from the consumerNode and: If it is null, the queue is empty. |
getSingleConsumerNodeValue, isEmpty, iterator, lpConsumerNode, lpProducerNode, lvConsumerNode, lvProducerNode, size, spConsumerNode, spProducerNode, toString, xchgProducerNode
contains, containsAll, remove, removeAll, retainAll, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public boolean offer(E e)
MessagePassingQueue#offer(Object)
,
Queue.offer(java.lang.Object)
public E poll()
public E peek()