abstract class MpmcConcurrentQueueSMBuffer<E> extends MpmcConcurrentQueueSMBufferL0Pad
Modifier and Type | Field and Description |
---|---|
protected E[] |
buffer |
private static int |
BUFFER_PAD |
protected int |
capacity |
protected long |
mask |
private static long |
REF_ARRAY_BASE |
private static int |
REF_ELEMENT_SHIFT |
protected static int |
SIZE_OF_ELEMENT |
private static int |
SPARSE_SHIFT |
Constructor and Description |
---|
MpmcConcurrentQueueSMBuffer(int capacity) |
MpmcConcurrentQueueSMBuffer(MpmcConcurrentQueueSMBuffer<E> c) |
Modifier and Type | Method and Description |
---|---|
protected long |
calcOffset(long index) |
protected java.lang.Object |
lvElement(E[] buffer,
long offset) |
protected void |
soElement(E[] buffer,
long offset,
java.lang.Object e) |
protected void |
spElement(E[] buffer,
long offset,
E e) |
protected void |
svElement(E[] buffer,
long offset,
java.lang.Object e) |
private static final int SPARSE_SHIFT
private static final int BUFFER_PAD
private static final long REF_ARRAY_BASE
private static final int REF_ELEMENT_SHIFT
protected static final int SIZE_OF_ELEMENT
protected final int capacity
protected final long mask
protected final E[] buffer
public MpmcConcurrentQueueSMBuffer(int capacity)
public MpmcConcurrentQueueSMBuffer(MpmcConcurrentQueueSMBuffer<E> c)
protected final long calcOffset(long index)
protected final void soElement(E[] buffer, long offset, java.lang.Object e)
protected final void svElement(E[] buffer, long offset, java.lang.Object e)
protected final java.lang.Object lvElement(E[] buffer, long offset)