public abstract class SpscChannelConsumer<E> extends SpscOffHeapFixedSizeRingBuffer implements ChannelConsumer
| Modifier and Type | Field and Description |
|---|---|
protected long |
pointer |
protected ChannelReceiver<E> |
receiver |
EOFbufferAddress, 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, writeReleasearrayIndexForCursor, 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, writeReleaseStateclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitreadprotected final ChannelReceiver<E> receiver
protected long pointer
public SpscChannelConsumer(java.nio.ByteBuffer buffer,
int capacity,
int messageSize,
ChannelReceiver<E> receiver)