E
- element type.public abstract class SpscChannelProducer<E> extends SpscOffHeapFixedSizeRingBuffer implements ChannelProducer<E>
Modifier and Type | Field and Description |
---|---|
protected long |
pointer |
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 |
---|
SpscChannelProducer(java.nio.ByteBuffer buffer,
int capacity,
int messageSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
claim()
Attempt to claim the next element in the channel.
|
boolean |
commit() |
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
currentElement
public SpscChannelProducer(java.nio.ByteBuffer buffer, int capacity, int messageSize)
public final boolean claim()
ChannelProducer
claim
in interface ChannelProducer<E>
this#commit()
public final boolean commit()
commit
in interface ChannelProducer<E>
this#claim()