Package org.jctools.channels.mpsc
Class MpscChannelConsumer<E>
java.lang.Object
org.jctools.channels.proxy.ProxyChannelRingBuffer
org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
org.jctools.channels.mpsc.MpscChannelConsumer<E>
- All Implemented Interfaces:
ChannelConsumer
public abstract class MpscChannelConsumer<E>
extends MpscOffHeapFixedSizeRingBuffer
implements ChannelConsumer
Package Scoped: not part of public API.
-
Field Summary
FieldsFields inherited from class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
bufferAddress, consumerIndexAddress, HEADER_SIZE, mask, MESSAGE_INDICATOR_SIZE, messageSize, producerIndexAddress, READ_ACQUIRE_INDICATOR, READ_RELEASE_INDICATOR, referenceMessageSize, references, WRITE_ACQUIRE_INDICATOR, WRITE_RELEASE_INDICATOR
Fields inherited from class org.jctools.channels.proxy.ProxyChannelRingBuffer
EOF
-
Constructor Summary
ConstructorsConstructorDescriptionMpscChannelConsumer
(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver) -
Method Summary
Methods inherited from class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
readAcquire, readRelease, writeAcquire, writeRelease, writeRelease
Methods inherited from class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
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
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.jctools.channels.ChannelConsumer
read
-
Field Details
-
receiver
-
pointer
protected long pointer
-
-
Constructor Details
-
MpscChannelConsumer
public MpscChannelConsumer(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)
-