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:
java.lang.Iterable<E>
,java.util.Collection<E>
,java.util.Queue<E>
- Direct Known Subclasses:
SpscAtomicArrayQueue
abstract class AtomicReferenceArrayQueue<E> extends java.util.AbstractQueue<E>
-
-
Constructor Summary
Constructors Constructor Description AtomicReferenceArrayQueue(int capacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected int
calcElementOffset(long index)
protected int
calcElementOffset(long index, int mask)
void
clear()
java.util.Iterator<E>
iterator()
protected E
lpElement(int offset)
protected E
lpElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset)
protected E
lvElement(int offset)
protected E
lvElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset)
protected void
soElement(int offset, E value)
protected void
soElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)
protected void
spElement(int offset, E value)
protected void
spElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)
protected void
svElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)
-
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
-
-
-
-
Field Detail
-
buffer
protected final java.util.concurrent.atomic.AtomicReferenceArray<E> buffer
-
mask
protected final int mask
-
-
Method Detail
-
iterator
public java.util.Iterator<E> iterator()
-
clear
public void clear()
-
calcElementOffset
protected final int calcElementOffset(long index, int mask)
-
calcElementOffset
protected final int calcElementOffset(long index)
-
lvElement
protected final E lvElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset)
-
lpElement
protected final E lpElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset)
-
lpElement
protected final E lpElement(int offset)
-
spElement
protected final void spElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)
-
spElement
protected final void spElement(int offset, E value)
-
soElement
protected final void soElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)
-
soElement
protected final void soElement(int offset, E value)
-
svElement
protected final void svElement(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, int offset, E value)
-
lvElement
protected final E lvElement(int offset)
-
-