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_INDICATOREOF| 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, 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, waitcurrentElementpublic MpscChannelProducer(java.nio.ByteBuffer buffer,
int capacity,
int messageSize)
public final boolean claim()
ChannelProducerclaim in interface ChannelProducer<E>this#commit()public final boolean commit()
commit in interface ChannelProducer<E>this#claim()