rxjava 1.3.8 · rx.internal.util.atomic.BaseLinkedAtomicQueue

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

Access	Constructor and Description
public	BaseLinkedAtomicQueue()

Method Summary

Modifier and Type	Method and Description
public final boolean	isEmpty() Overrides java.util.AbstractCollection.isEmpty. Implements java.util.Collection.isEmpty. Returns `true` if this collection contains no elements.
public final Iterator<E>	iterator() Implements abstract java.util.AbstractCollection.iterator. Implements java.util.Collection.iterator. Returns an iterator over the elements in this collection.
protected final LinkedQueueNode<E>	lpConsumerNode()
protected final LinkedQueueNode<E>	lpProducerNode()
protected final LinkedQueueNode<E>	lvConsumerNode()
protected final LinkedQueueNode<E>	lvProducerNode()
public final int	size() Implements abstract java.util.AbstractCollection.size. Implements java.util.Collection.size. Returns the number of elements in this collection.
protected final void	spConsumerNode(LinkedQueueNode<E> node)
protected final void	spProducerNode(LinkedQueueNode<E> node)
protected final LinkedQueueNode<E>	xchgProducerNode(LinkedQueueNode<E> node)

Inherited from java.util.AbstractQueue:: add addAll clear element remove

consumerNode	back to summary
private final AtomicReference<LinkedQueueNode<E>> consumerNode

producerNode	back to summary
private final AtomicReference<LinkedQueueNode<E>> producerNode

BaseLinkedAtomicQueue	back to summary
public BaseLinkedAtomicQueue()

Method Detail

isEmpty back to summary

isEmpty	back to summary
public final boolean isEmpty() Overrides java.util.AbstractCollection.isEmpty. Implements java.util.Collection.isEmpty. Doc from java.util.Collection.isEmpty. Returns `true` if this collection contains no elements. 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. Returns:boolean `true` if this collection contains no elements Annotations @Override

public final boolean isEmpty()

Overrides java.util.AbstractCollection.isEmpty.

Implements java.util.Collection.isEmpty.

Doc from java.util.Collection.isEmpty.

Returns true if this collection contains no elements.

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.

Returns:boolean

true if this collection contains no elements

Annotations

@Override

iterator back to summary

iterator	back to summary
public final Iterator<E> iterator() Implements abstract java.util.AbstractCollection.iterator. Implements java.util.Collection.iterator. Doc from java.util.Collection.iterator. Returns an iterator over the elements in this collection. There are no guarantees concerning the order in which the elements are returned (unless this collection is an instance of some class that provides a guarantee). Returns:Iterator<E> an `Iterator` over the elements in this collection Annotations @Override

public final Iterator<E> iterator()

Implements abstract java.util.AbstractCollection.iterator.

Implements java.util.Collection.iterator.

Doc from java.util.Collection.iterator.

Returns an iterator over the elements in this collection. There are no guarantees concerning the order in which the elements are returned (unless this collection is an instance of some class that provides a guarantee).

Returns:Iterator<E>

an Iterator over the elements in this collection

Annotations

@Override

lpConsumerNode	back to summary
protected final LinkedQueueNode<E> lpConsumerNode()

lpProducerNode	back to summary
protected final LinkedQueueNode<E> lpProducerNode()

lvConsumerNode	back to summary
protected final LinkedQueueNode<E> lvConsumerNode()

lvProducerNode	back to summary
protected final LinkedQueueNode<E> lvProducerNode()

size back to summary

size	back to summary
public final int size() Implements abstract java.util.AbstractCollection.size. Implements java.util.Collection.size. Doc from java.util.Collection.size. Returns the number of elements in this collection. If this collection contains more than `Integer.MAX_VALUE` elements, returns `Integer.MAX_VALUE`. Implementation Notes This is an O(n) operation as we run through all the nodes and count them. Returns:int the number of elements in this collection Annotations @Override See Also `java.util.Queue#size()`

public final int size()

Implements abstract java.util.AbstractCollection.size.

Implements java.util.Collection.size.

Doc from java.util.Collection.size.

Returns the number of elements in this collection. If this collection contains more than Integer.MAX_VALUE elements, returns Integer.MAX_VALUE.

Implementation Notes

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

Returns:int

the number of elements in this collection

Annotations

@Override

See Also

java.util.Queue#size()

spConsumerNode	back to summary
protected final void spConsumerNode(LinkedQueueNode<E> node)

spProducerNode	back to summary
protected final void spProducerNode(LinkedQueueNode<E> node)

xchgProducerNode	back to summary
protected final LinkedQueueNode<E> xchgProducerNode(LinkedQueueNode<E> node)

pack-priv abstract Class BaseLinkedAtomicQueue<E>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail