E
- public final class MpscLinkedAtomicQueue<E> extends BaseLinkedAtomicQueue<E>
Constructor and Description |
---|
MpscLinkedAtomicQueue() |
Modifier and Type | Method and Description |
---|---|
boolean |
offer(E e)
|
E |
peek() |
E |
poll()
|
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 final boolean offer(E e)
IMPLEMENTATION NOTES:
Offer is allowed from multiple threads.
Offer allocates a new node and:
MessagePassingQueue.offer(Object)
,
Queue.offer(java.lang.Object)
public final E poll()
IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and:
MessagePassingQueue.poll()
,
Queue.poll()
public final E peek()