Top Fields Constructors Methods
io.netty5.util.internal.shaded.org.jctools.queues

pack-priv abstract Class MpscBlockingConsumerArrayQueueConsumerFields<E>

Located in compilation unit of io.netty5.util.internal.shaded.org.jctools.queues.MpscBlockingConsumerArrayQueue.

extends MpscBlockingConsumerArrayQueuePad3<E>
Class Inheritance
Known Direct Subclasses
io.netty5.util.internal.shaded.org.jctools.queues.MpscBlockingConsumerArrayQueue

Field Summary

Modifier and TypeField and Description
private volatile Thread
blocked

private static final long
BLOCKED_OFFSET

private static final long
C_INDEX_OFFSET

protected final E[]
consumerBuffer

private volatile long
consumerIndex

protected final long
consumerMask

Inherited from io.netty5.util.internal.shaded.org.jctools.queues.MpscBlockingConsumerArrayQueuePad3:
b000b001b002b003b004b005b006b007b010b011b012b013b014b015b016b017b020b021b022b023b024b025b026b027b030b031b032b033b034b035b036b037b040b041b042b043b044b045b046b047b050b051b052b053b054b055b056b057b060b061b062b063b064b065b066b067b070b071b072b073b074b075b076b077b100b101b102b103b104b105b106b107b110b111b112b113b114b115b116b117b120b121b122b123b124b125b126b127b130b131b132b133b134b135b136b137b140b141b142b143b144b145b146b147b150b151b152b153b154b155b156b157b160b161b162b163b164b165b166b167b170b171b172b173b174b175b176b177

Constructor Summary

AccessConstructor and Description
pack-priv
MpscBlockingConsumerArrayQueueConsumerFields(long mask, E[] buffer)

Method Summary

Modifier and TypeMethod and Description
pack-priv final long
lpConsumerIndex()

pack-priv final Thread
lvBlocked()

public final long
lvConsumerIndex()

Implements io.netty5.util.internal.shaded.org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue.lvConsumerIndex.

pack-priv final void
soBlocked(Thread
the consumer thread which is blocked waiting for the producers
thread)

This field should only be written to from the consumer thread.

pack-priv final void
soConsumerIndex(long newValue)

Field Detail

blockedback to summary
private volatile Thread blocked
BLOCKED_OFFSETback to summary
private static final long BLOCKED_OFFSET
C_INDEX_OFFSETback to summary
private static final long C_INDEX_OFFSET
consumerBufferback to summary
protected final E[] consumerBuffer
consumerIndexback to summary
private volatile long consumerIndex
consumerMaskback to summary
protected final long consumerMask

Constructor Detail

MpscBlockingConsumerArrayQueueConsumerFieldsback to summary
pack-priv MpscBlockingConsumerArrayQueueConsumerFields(long mask, E[] buffer)

Method Detail

lpConsumerIndexback to summary
pack-priv final long lpConsumerIndex()
lvBlockedback to summary
pack-priv final Thread lvBlocked()
lvConsumerIndexback to summary
public final long lvConsumerIndex()

Implements io.netty5.util.internal.shaded.org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue.lvConsumerIndex.

Annotations
@Override
soBlockedback to summary
pack-priv final void soBlocked(Thread thread)

This field should only be written to from the consumer thread. It is set before parking the consumer and nulled when the consumer is unblocked. The value is read by producer thread to unpark the consumer.

Parameters
thread:Thread

the consumer thread which is blocked waiting for the producers

soConsumerIndexback to summary
pack-priv final void soConsumerIndex(long newValue)