Package rx.internal.util.unsafe

Class MpmcArrayQueueL2Pad<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

rx.internal.util.unsafe.ConcurrentCircularArrayQueueL0Pad<E>

rx.internal.util.unsafe.ConcurrentCircularArrayQueue<E>

rx.internal.util.unsafe.ConcurrentSequencedCircularArrayQueue<E>

rx.internal.util.unsafe.MpmcArrayQueueL1Pad<E>

rx.internal.util.unsafe.MpmcArrayQueueProducerField<E>

rx.internal.util.unsafe.MpmcArrayQueueL2Pad<E>

All Implemented Interfaces:

Iterable<E>, Collection<E>, Queue<E>, MessagePassingQueue<E>

Direct Known Subclasses:

MpmcArrayQueueConsumerField

abstract class MpmcArrayQueueL2Pad<E>
extends MpmcArrayQueueProducerField<E>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) long	p20
(package private) long	p21
(package private) long	p22
(package private) long	p23
(package private) long	p24
(package private) long	p25
(package private) long	p26
(package private) long	p30
(package private) long	p31
(package private) long	p32
(package private) long	p33
(package private) long	p34
(package private) long	p35
(package private) long	p36
(package private) long	p37

Fields inherited from class rx.internal.util.unsafe.MpmcArrayQueueL1Pad

p10, p11, p12, p13, p14, p15, p16

Fields inherited from class rx.internal.util.unsafe.ConcurrentSequencedCircularArrayQueue

sequenceBuffer

Fields inherited from class rx.internal.util.unsafe.ConcurrentCircularArrayQueue

buffer, BUFFER_PAD, mask, SPARSE_SHIFT

Fields inherited from class rx.internal.util.unsafe.ConcurrentCircularArrayQueueL0Pad

p00, p01, p02, p03, p04, p05, p06, p07

Constructor Summary

Constructors

Constructor	Description
MpmcArrayQueueL2Pad(int capacity)

Method Summary

Methods inherited from class rx.internal.util.unsafe.MpmcArrayQueueProducerField

casProducerIndex, lvProducerIndex

Methods inherited from class rx.internal.util.unsafe.ConcurrentSequencedCircularArrayQueue

calcSequenceOffset, lvSequence, soSequence

Methods inherited from class rx.internal.util.unsafe.ConcurrentCircularArrayQueue

calcElementOffset, calcElementOffset, clear, iterator, lpElement, lpElement, lvElement, lvElement, soElement, soElement, spElement, spElement

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, size, toArray, toArray, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

contains, containsAll, equals, hashCode, isEmpty, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface rx.internal.util.unsafe.MessagePassingQueue

isEmpty, offer, peek, poll, size

Methods inherited from interface java.util.Queue

offer, peek, poll

Field Details

p20

long p20

p21

long p21

p22

long p22

p23

long p23

p24

long p24

p25

long p25

p26

long p26

p30

long p30

p31

long p31

p32

long p32

p33

long p33

p34

long p34

p35

long p35

p36

long p36

p37

long p37

Constructor Details

MpmcArrayQueueL2Pad

public MpmcArrayQueueL2Pad(int capacity)