static final class MpmcArrayConcurrentQueueColdFields.Producer<E> extends MpmcArrayConcurrentQueueColdFields.ProducerFields<E> implements ConcurrentQueueProducer<E>
| Modifier and Type | Field and Description |
|---|---|
(package private) long |
p00 |
(package private) long |
p01 |
(package private) long |
p02 |
(package private) long |
p03 |
(package private) long |
p04 |
(package private) long |
p05 |
(package private) long |
p06 |
(package private) long |
p07 |
(package private) long |
p10 |
(package private) long |
p11 |
(package private) long |
p12 |
(package private) long |
p13 |
(package private) long |
p14 |
(package private) long |
p15 |
(package private) long |
p16 |
(package private) long |
p17 |
consumer, P_INDEX_OFFSETsequenceBufferbuffer, BUFFER_PAD, mask, SPARSE_SHIFT| Constructor and Description |
|---|
Producer(ConcurrentSequencedCircularArray<E> c) |
| Modifier and Type | Method and Description |
|---|---|
private void |
addElement(long[] sBuffer,
E[] eBuffer,
long mask,
long index,
long sOffset,
E e) |
boolean |
offer(E e) |
int |
produce(ProducerFunction<E> producer,
int batchSize) |
boolean |
weakOffer(E e) |
private boolean |
weakOffer(long[] sBuffer,
E[] eBuffer,
long mask,
E e) |
casProducerIndex, lvProducerIndexcalcSequenceOffset, calcSequenceOffset, lpSequence, lpSequenceElement, lvSequence, lvSequence, soSequence, soSequenceElement, spSequenceElement, spSequenceElement, svSequenceElement, svSequenceElementcalcOffset, calcOffset, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement, svElement, svElementlong p00
long p01
long p02
long p03
long p04
long p05
long p06
long p07
long p10
long p11
long p12
long p13
long p14
long p15
long p16
long p17
public Producer(ConcurrentSequencedCircularArray<E> c)
public boolean offer(E e)
offer in interface ConcurrentQueueProducer<E>private void addElement(long[] sBuffer,
E[] eBuffer,
long mask,
long index,
long sOffset,
E e)
public boolean weakOffer(E e)
weakOffer in interface ConcurrentQueueProducer<E>public int produce(ProducerFunction<E> producer, int batchSize)
produce in interface ConcurrentQueueProducer<E>