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, 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, writeReleasecapacity, getRequiredBufferSize, isEmpty, isReadReleased, lpConsumerIndex, lpProducerIndex, lvConsumerIndex, lvProducerIndex, offsetForIndex, offsetForIndex, readAcquireState, readReleaseState, size, soConsumerIndex, soProducerIndex, writeAcquireState, 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)