Package org.jctools.queues
Class MpscLinkedArrayQueue<T>
java.lang.Object
java.util.AbstractCollection<T>
java.util.AbstractQueue<T>
org.jctools.queues.MpscLinkedArrayQueue<T>
- All Implemented Interfaces:
Iterable<T>
,Collection<T>
,Queue<T>
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final Object
(package private) MpscLinkedArrayQueue.ARA2
(package private) final AtomicLong
(package private) int
(package private) final int
(package private) final AtomicReference
<MpscLinkedArrayQueue.ARA2> (package private) final AtomicLong
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class java.util.AbstractCollection
contains, containsAll, remove, removeAll, retainAll, 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, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArray
-
Field Details
-
producerIndex
-
producerArray
-
consumerIndex
-
consumerArray
MpscLinkedArrayQueue.ARA2 consumerArray -
consumerOffset
int consumerOffset -
maxOffset
final int maxOffset -
ALLOCATING
-
-
Constructor Details
-
MpscLinkedArrayQueue
public MpscLinkedArrayQueue(int arrayCapacity)
-
-
Method Details
-
offer
-
poll
-
weakPoll
-
peek
-
weakPeek
-
isEmpty
public boolean isEmpty()- Specified by:
isEmpty
in interfaceCollection<T>
- Overrides:
isEmpty
in classAbstractCollection<T>
-
size
public int size()- Specified by:
size
in interfaceCollection<T>
- Specified by:
size
in classAbstractCollection<T>
-
iterator
- Specified by:
iterator
in interfaceCollection<T>
- Specified by:
iterator
in interfaceIterable<T>
- Specified by:
iterator
in classAbstractCollection<T>
-