Constructor Detail

• SpscLinkedAtomicQueue

  public SpscLinkedAtomicQueue()

Method Detail

• offer

  public boolean offer(E nextValue)

  
  IMPLEMENTATION NOTES:
  Offer is allowed from a SINGLE thread.
  Offer allocates a new node (holding the offered value) and:

  1. Sets that node as the producerNode.next
  2. 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.

  See Also:

  MessagePassingQueue#offer(Object), Queue.offer(java.lang.Object)

• poll

  public E poll()

  
  IMPLEMENTATION NOTES:
  Poll is allowed from a SINGLE thread.
  Poll reads the next node from the consumerNode and:

  1. If it is null, the queue is empty.
  2. If it is not null set it as the consumer node and return it's now evacuated value.

  This means the consumerNode.value is always null, which is also the starting point for the queue. Because null values are not allowed to be offered this is the only node with it's value set to null at any one time.

• peek

  public E peek()

• lvProducerNode

  protected final LinkedQueueNode<E> lvProducerNode()

• lpProducerNode

  protected final LinkedQueueNode<E> lpProducerNode()

• spProducerNode

  protected final void spProducerNode(LinkedQueueNode<E> node)

• xchgProducerNode

  protected final LinkedQueueNode<E> xchgProducerNode(LinkedQueueNode<E> node)

• lvConsumerNode

  protected final LinkedQueueNode<E> lvConsumerNode()

• lpConsumerNode

  protected final LinkedQueueNode<E> lpConsumerNode()

• spConsumerNode

  protected final void spConsumerNode(LinkedQueueNode<E> node)

• iterator

  public final Iterator<E> iterator()

• size

  public final int size()

  
  

  IMPLEMENTATION NOTES:
  This is an O(n) operation as we run through all the nodes and count them.
  

  Specified by:

  size in interface  Collection<E>

  Specified by:

  size in class  AbstractCollection<E>

  See Also:

  Collection.size()

• isEmpty

  public final boolean isEmpty()

  
  

  IMPLEMENTATION NOTES:
  Queue is empty when producerNode is the same as consumerNode. An alternative implementation would be to observe the producerNode.value is null, which also means an empty queue because only the consumerNode.value is allowed to be null.

  Specified by:

  isEmpty in interface  Collection<E>

  Overrides:

  isEmpty in class  AbstractCollection<E>

  See Also:

  MessagePassingQueue#isEmpty()