Package org.jctools.queues.alt

Class MpscArrayConcurrentQueueColdFields.ProducerFields<E>

java.lang.Object

org.jctools.queues.alt.ConcurrentCircularArrayL0Pad<E>

org.jctools.queues.alt.ConcurrentCircularArray<E>

org.jctools.queues.alt.ConcurrentSequencedCircularArray<E>

org.jctools.queues.alt.MpscArrayConcurrentQueueColdFields.ProducerFields<E>

Direct Known Subclasses:

MpscArrayConcurrentQueueColdFields.Producer

Enclosing class:

MpscArrayConcurrentQueueColdFields<E>

private abstract static class MpscArrayConcurrentQueueColdFields.ProducerFields<E>
extends ConcurrentSequencedCircularArray<E>

Field Summary

Fields

Modifier and Type	Field	Description
protected MpscArrayConcurrentQueueColdFields.Consumer<E>	consumer
protected static long	P_INDEX_OFFSET
private long	producerIndex

Fields inherited from class org.jctools.queues.alt.ConcurrentSequencedCircularArray

sequenceBuffer

Fields inherited from class org.jctools.queues.alt.ConcurrentCircularArray

buffer, BUFFER_PAD, mask, SPARSE_SHIFT

Fields inherited from class org.jctools.queues.alt.ConcurrentCircularArrayL0Pad

b000, b001, b002, b003, b004, b005, b006, b007, b010, b011, b012, b013, b014, b015, b016, b017, b020, b021, b022, b023, b024, b025, b026, b027, b030, b031, b032, b033, b034, b035, b036, b037, b040, b041, b042, b043, b044, b045, b046, b047, b050, b051, b052, b053, b054, b055, b056, b057, b060, b061, b062, b063, b064, b065, b066, b067, b070, b071, b072, b073, b074, b075, b076, b077, b100, b101, b102, b103, b104, b105, b106, b107, b110, b111, b112, b113, b114, b115, b116, b117, b120, b121, b122, b123, b124, b125, b126, b127, b130, b131, b132, b133, b134, b135, b136, b137, b140, b141, b142, b143, b144, b145, b146, b147, b150, b151, b152, b153, b154, b155, b156, b157, b160, b161, b162, b163, b164, b165, b166, b167, b170, b171, b172, b173, b174, b175, b176, b177

Constructor Summary

Constructors

Constructor	Description
ProducerFields(ConcurrentSequencedCircularArray<E> c)

Method Summary

Modifier and Type	Method	Description
protected boolean	casProducerIndex(long expect, long newValue)
protected long	lvProducerIndex()

Methods inherited from class org.jctools.queues.alt.ConcurrentSequencedCircularArray

calcSequenceOffset, calcSequenceOffset, lpSequence, lpSequenceElement, lvSequence, lvSequence, soSequence, soSequenceElement, spSequenceElement, spSequenceElement, svSequenceElement, svSequenceElement

Methods inherited from class org.jctools.queues.alt.ConcurrentCircularArray

calcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElement

Methods inherited from class java.lang.Object

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

Field Detail

P_INDEX_OFFSET

protected static final long P_INDEX_OFFSET

consumer

protected MpscArrayConcurrentQueueColdFields.Consumer<E> consumer

producerIndex

private volatile long producerIndex

Constructor Detail

ProducerFields

public ProducerFields(ConcurrentSequencedCircularArray<E> c)

Method Detail

lvProducerIndex

protected final long lvProducerIndex()

casProducerIndex

protected final boolean casProducerIndex(long expect,
                                         long newValue)