public final class MpscLinkedArrayQueue<T>
extends java.util.AbstractQueue<T>
Modifier and Type | Class and Description |
---|---|
(package private) static class |
MpscLinkedArrayQueue.ARA2 |
Modifier and Type | Field and Description |
---|---|
(package private) static java.lang.Object |
ALLOCATING |
(package private) MpscLinkedArrayQueue.ARA2 |
consumerArray |
(package private) java.util.concurrent.atomic.AtomicLong |
consumerIndex |
(package private) int |
consumerOffset |
(package private) int |
maxOffset |
(package private) java.util.concurrent.atomic.AtomicReference<MpscLinkedArrayQueue.ARA2> |
producerArray |
(package private) java.util.concurrent.atomic.AtomicLong |
producerIndex |
Constructor and Description |
---|
MpscLinkedArrayQueue(int arrayCapacity) |
Modifier and Type | Method and Description |
---|---|
boolean |
isEmpty() |
java.util.Iterator<T> |
iterator() |
boolean |
offer(T value) |
T |
peek() |
T |
poll() |
int |
size() |
T |
weakPeek() |
T |
weakPoll() |
contains, containsAll, remove, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
final java.util.concurrent.atomic.AtomicLong producerIndex
final java.util.concurrent.atomic.AtomicReference<MpscLinkedArrayQueue.ARA2> producerArray
final java.util.concurrent.atomic.AtomicLong consumerIndex
MpscLinkedArrayQueue.ARA2 consumerArray
int consumerOffset
final int maxOffset
static final java.lang.Object ALLOCATING