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
Fields Modifier and Type Field Description protected long
pointer
protected ChannelReceiver<E>
receiver
-
Fields 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
Constructors Constructor Description SpscChannelConsumer(java.nio.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 Detail
-
receiver
protected final ChannelReceiver<E> receiver
-
pointer
protected long pointer
-
-
Constructor Detail
-
SpscChannelConsumer
public SpscChannelConsumer(java.nio.ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)
-
-