public abstract class SpscChannelConsumer<E> extends SpscOffHeapFixedSizeRingBuffer implements ChannelConsumer
Modifier and Type | Field and Description |
---|---|
protected long |
pointer |
protected ChannelReceiver<E> |
receiver |
EOF
bufferAddress, consumerIndexAddress, HEADER_SIZE, mask, MESSAGE_INDICATOR_SIZE, messageSize, producerIndexAddress, READ_ACQUIRE_INDICATOR, READ_RELEASE_INDICATOR, referenceMessageSize, references, WRITE_ACQUIRE_INDICATOR, WRITE_RELEASE_INDICATOR
Constructor and Description |
---|
SpscChannelConsumer(java.nio.ByteBuffer buffer,
int capacity,
int messageSize,
ChannelReceiver<E> receiver) |
getLookaheadStep, 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 SpscChannelConsumer(java.nio.ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)