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

Fields

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

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

Fields inherited from class org.jctools.channels.proxy.ProxyChannelRingBuffer

EOF

Constructor Summary

Constructors

Constructor	Description
MpscChannelConsumer(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

protected final ChannelReceiver<E> receiver

pointer

protected long pointer

Constructor Details

MpscChannelConsumer

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