public class MpscOffHeapFixedSizeRingBuffer extends OffHeapFixedMessageSizeRingBuffer
bufferAddress, consumerIndexAddress, EOF, 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 |
MpscOffHeapFixedSizeRingBuffer(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.
|
|
MpscOffHeapFixedSizeRingBuffer(int capacity,
int messageSize) |
Modifier and Type | Method and Description |
---|---|
protected long |
readAcquire() |
protected void |
readRelease(long offset) |
protected long |
writeAcquire() |
protected void |
writeRelease(long offset) |
capacity, getRequiredBufferSize, isEmpty, isReadReleased, lpConsumerIndex, lpProducerIndex, lvConsumerIndex, lvProducerIndex, offsetForIndex, offsetForIndex, readAcquireState, readReleaseState, size, soConsumerIndex, soProducerIndex, writeAcquireState, writeReleaseState
public MpscOffHeapFixedSizeRingBuffer(int capacity, int messageSize)
protected MpscOffHeapFixedSizeRingBuffer(ByteBuffer buff, int capacity, boolean isProducer, boolean isConsumer, boolean initialize, int messageSize)
buff
- 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 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-2016. All Rights Reserved.