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 final ChannelReceiver<E>	receiver

Fields inherited from class SpscOffHeapFixedSizeRingBuffer

EOF

Fields inherited from class 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(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)

Method Summary

Methods inherited from class SpscOffHeapFixedSizeRingBuffer

getLookaheadStep, readAcquire, readRelease, writeAcquire, writeRelease, writeRelease

Methods inherited from class 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ChannelConsumer

read

Field Details

receiver

protected final ChannelReceiver<E> receiver

pointer

protected long pointer

Constructor Details

SpscChannelConsumer

public SpscChannelConsumer(ByteBuffer buffer,
 int capacity,
 int messageSize,
 ChannelReceiver<E> receiver)