Package rx.internal.util.atomic

Class BaseLinkedAtomicQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

rx.internal.util.atomic.BaseLinkedAtomicQueue<E>

All Implemented Interfaces:

Iterable<E>, Collection<E>, Queue<E>

Direct Known Subclasses:

MpscLinkedAtomicQueue, SpscLinkedAtomicQueue

abstract class BaseLinkedAtomicQueue<E>
extends AbstractQueue<E>

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicReference<LinkedQueueNode<E>>	consumerNode
private final AtomicReference<LinkedQueueNode<E>>	producerNode

Constructor Summary

Constructors

Constructor	Description
BaseLinkedAtomicQueue()

Method Summary

Modifier and Type	Method	Description
final boolean	isEmpty()
final Iterator<E>	iterator()
protected final LinkedQueueNode<E>	lpConsumerNode()
protected final LinkedQueueNode<E>	lpProducerNode()
protected final LinkedQueueNode<E>	lvConsumerNode()
protected final LinkedQueueNode<E>	lvProducerNode()
final int	size()
protected final void	spConsumerNode(LinkedQueueNode<E> node)
protected final void	spProducerNode(LinkedQueueNode<E> node)
protected final LinkedQueueNode<E>	xchgProducerNode(LinkedQueueNode<E> node)

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

contains, containsAll, equals, hashCode, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Queue

offer, peek, poll

Field Details

producerNode

private final AtomicReference<LinkedQueueNode<E>> producerNode

consumerNode

private final AtomicReference<LinkedQueueNode<E>> consumerNode

Constructor Details

BaseLinkedAtomicQueue

public BaseLinkedAtomicQueue()

Method Details

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()

Specified by:

iterator in interface Collection<E>

Specified by:

iterator in interface Iterable<E>

Specified by:

iterator in class AbstractCollection<E>

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>