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

Fields

Modifier and Type	Field	Description
protected long	pointer
protected final ChannelReceiver<E>	receiver

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

Fields inherited from class ProxyChannelRingBuffer

EOF

Constructor Summary

Constructors

Constructor	Description
MpscChannelConsumer(ByteBuffer buffer, int capacity, int messageSize, ChannelReceiver<E> receiver)

Method Summary

Methods inherited from class MpscOffHeapFixedSizeRingBuffer

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

MpscChannelConsumer

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