public abstract class MpscChannelConsumer<E> extends MpscOffHeapFixedSizeRingBuffer implements ChannelConsumer
Modifier and Type | Field and Description |
---|---|
protected long |
pointer |
protected ChannelReceiver<E> |
receiver |
bufferAddress, consumerIndexAddress, HEADER_SIZE, mask, MESSAGE_INDICATOR_SIZE, messageSize, producerIndexAddress, READ_ACQUIRE_INDICATOR, READ_RELEASE_INDICATOR, referenceMessageSize, references, WRITE_ACQUIRE_INDICATOR, WRITE_RELEASE_INDICATOR
EOF
Constructor and Description |
---|
MpscChannelConsumer(java.nio.ByteBuffer buffer,
int capacity,
int messageSize,
ChannelReceiver<E> receiver) |
readAcquire, readRelease, writeAcquire, writeRelease, writeRelease
arrayIndexForCursor, arrayIndexForCursor, capacity, consumerReferenceArrayIndex, createReferenceArray, getRequiredArraySize, getRequiredBufferSize, isEmpty, isReadReleased, lpConsumerIndex, lpProducerIndex, lvConsumerIndex, lvProducerIndex, offsetForIndex, offsetForIndex, producerReferenceArrayIndex, readAcquireState, readReference, readReleaseState, relativeIndexForOffset, relativeIndexForOffset, size, soConsumerIndex, soProducerIndex, writeAcquireState, writeReference, writeReleaseState
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
read
protected final ChannelReceiver<E> receiver
protected long pointer
public MpscChannelConsumer(java.nio.ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)