Package rx.internal.util.unsafe
Class ConcurrentSequencedCircularArrayQueue<E>
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
rx.internal.util.unsafe.ConcurrentCircularArrayQueueL0Pad<E>
rx.internal.util.unsafe.ConcurrentCircularArrayQueue<E>
rx.internal.util.unsafe.ConcurrentSequencedCircularArrayQueue<E>
- All Implemented Interfaces:
Iterable<E>
,Collection<E>
,Queue<E>
,MessagePassingQueue<E>
- Direct Known Subclasses:
MpmcArrayQueueL1Pad
@SuppressAnimalSniffer
public abstract class ConcurrentSequencedCircularArrayQueue<E>
extends ConcurrentCircularArrayQueue<E>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final long
private static final int
protected final long[]
Fields inherited from class rx.internal.util.unsafe.ConcurrentCircularArrayQueue
buffer, BUFFER_PAD, mask, SPARSE_SHIFT
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final long
calcSequenceOffset
(long index) protected final long
lvSequence
(long[] buffer, long offset) protected final void
soSequence
(long[] buffer, long offset, long e) Methods inherited from class rx.internal.util.unsafe.ConcurrentCircularArrayQueue
calcElementOffset, calcElementOffset, clear, iterator, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement
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
-
Field Details
-
ARRAY_BASE
private static final long ARRAY_BASE -
ELEMENT_SHIFT
private static final int ELEMENT_SHIFT -
sequenceBuffer
protected final long[] sequenceBuffer
-
-
Constructor Details
-
ConcurrentSequencedCircularArrayQueue
public ConcurrentSequencedCircularArrayQueue(int capacity)
-
-
Method Details
-
calcSequenceOffset
protected final long calcSequenceOffset(long index) -
soSequence
protected final void soSequence(long[] buffer, long offset, long e) -
lvSequence
protected final long lvSequence(long[] buffer, long offset)
-