Package rx.internal.util.atomic

Class AtomicReferenceArrayQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

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

All Implemented Interfaces:

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

Direct Known Subclasses:

SpscAtomicArrayQueue

abstract class AtomicReferenceArrayQueue<E>
extends AbstractQueue<E>

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicReferenceArray<E>	buffer
protected final int	mask

Constructor Summary

Constructors

Constructor	Description
AtomicReferenceArrayQueue(int capacity)

Method Summary

Modifier and Type	Method	Description
protected final int	calcElementOffset(long index)
protected final int	calcElementOffset(long index, int mask)
void	clear()
Iterator<E>	iterator()
protected final E	lpElement(int offset)
protected final E	lpElement(AtomicReferenceArray<E> buffer, int offset)
protected final E	lvElement(int offset)
protected final E	lvElement(AtomicReferenceArray<E> buffer, int offset)
protected final void	soElement(int offset, E value)
protected final void	soElement(AtomicReferenceArray<E> buffer, int offset, E value)
protected final void	spElement(int offset, E value)
protected final void	spElement(AtomicReferenceArray<E> buffer, int offset, E value)
protected final void	svElement(AtomicReferenceArray<E> buffer, int offset, E value)

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, size, 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, isEmpty, parallelStream, remove, removeAll, removeIf, retainAll, size, 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

buffer

protected final AtomicReferenceArray<E> buffer

mask

protected final int mask

Constructor Details

AtomicReferenceArrayQueue

public AtomicReferenceArrayQueue(int capacity)

Method Details

iterator

public Iterator<E> iterator()

Specified by:

iterator in interface Collection<E>

Specified by:

iterator in interface Iterable<E>

Specified by:

iterator in class AbstractCollection<E>

clear

public void clear()

Specified by:

clear in interface Collection<E>

Overrides:

clear in class AbstractQueue<E>

calcElementOffset

protected final int calcElementOffset(long index,
 int mask)

calcElementOffset

protected final int calcElementOffset(long index)

lvElement

protected final E lvElement(AtomicReferenceArray<E> buffer,
 int offset)

lpElement

protected final E lpElement(AtomicReferenceArray<E> buffer,
 int offset)

lpElement

protected final E lpElement(int offset)

spElement

protected final void spElement(AtomicReferenceArray<E> buffer,
 int offset,
 E value)

spElement

protected final void spElement(int offset,
 E value)

soElement

protected final void soElement(AtomicReferenceArray<E> buffer,
 int offset,
 E value)

soElement

protected final void soElement(int offset,
 E value)

svElement

protected final void svElement(AtomicReferenceArray<E> buffer,
 int offset,
 E value)

lvElement

protected final E lvElement(int offset)