Package org.jctools.channels.spsc
Class SpscChannelConsumer<E>
java.lang.Object
org.jctools.channels.proxy.ProxyChannelRingBuffer
org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
org.jctools.channels.spsc.SpscChannelConsumer<E>
- All Implemented Interfaces:
ChannelConsumer
public abstract class SpscChannelConsumer<E>
extends SpscOffHeapFixedSizeRingBuffer
implements ChannelConsumer
Package Scoped: not part of public API.
-
Field Summary
FieldsFields inherited from class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
EOF
Fields 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
-
Constructor Summary
ConstructorsConstructorDescriptionSpscChannelConsumer
(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver) -
Method Summary
Methods inherited from class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
getLookaheadStep, 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
-
SpscChannelConsumer
public SpscChannelConsumer(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)
-