E
- element type.public abstract class MpscChannelProducer<E> extends MpscOffHeapFixedSizeRingBuffer implements ChannelProducer<E>
Modifier and Type | Field and Description |
---|---|
protected long |
pointer |
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 |
---|
MpscChannelProducer(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() |
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 MpscChannelProducer(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()