public class SpscOffHeapFixedSizeRingBuffer extends OffHeapFixedMessageSizeRingBuffer
Modifier and Type | Field and Description |
---|---|
static long |
EOF |
bufferAddress, consumerIndexAddress, HEADER_SIZE, mask, MESSAGE_INDICATOR_SIZE, messageSize, producerIndexAddress, READ_ACQUIRE_INDICATOR, READ_RELEASE_INDICATOR, WRITE_ACQUIRE_INDICATOR, WRITE_RELEASE_INDICATOR
Modifier | Constructor and Description |
---|---|
protected |
SpscOffHeapFixedSizeRingBuffer(ByteBuffer buff,
int capacity,
boolean isProducer,
boolean isConsumer,
boolean initialize,
int messageSize)
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
|
|
SpscOffHeapFixedSizeRingBuffer(int capacity,
int messageSize) |
Modifier and Type | Method and Description |
---|---|
static int |
getLookaheadStep(int capacity) |
protected long |
readAcquire() |
protected void |
readRelease(long offset) |
protected long |
writeAcquire() |
protected void |
writeRelease(long offset) |
protected void |
writeRelease(long offset,
int type) |
capacity, getRequiredBufferSize, isEmpty, isReadReleased, lpConsumerIndex, lpProducerIndex, lvConsumerIndex, lvProducerIndex, offsetForIndex, offsetForIndex, readAcquireState, readReleaseState, size, soConsumerIndex, soProducerIndex, writeAcquireState, writeReleaseState
public static final long EOF
public SpscOffHeapFixedSizeRingBuffer(int capacity, int messageSize)
protected SpscOffHeapFixedSizeRingBuffer(ByteBuffer buff, int capacity, boolean isProducer, boolean isConsumer, boolean initialize, int messageSize)
buff
- capacity
- in messages, actual capacity will bemessageSize
- public static int getLookaheadStep(int capacity)
protected final long writeAcquire()
writeAcquire
in class OffHeapFixedMessageSizeRingBuffer
protected final void writeRelease(long offset)
writeRelease
in class OffHeapFixedMessageSizeRingBuffer
offset
- the base address of a message that we are done writing and can be read nowprotected final void writeRelease(long offset, int type)
protected final long readAcquire()
readAcquire
in class OffHeapFixedMessageSizeRingBuffer
protected final void readRelease(long offset)
readRelease
in class OffHeapFixedMessageSizeRingBuffer
offset
- the base address of a message that we are done reading and can be overwritten nowCopyright © 2013–2018. All rights reserved.