private static class BaseMpscLinkedAtomicArrayQueue.WeakIterator<E>
extends java.lang.Object
implements java.util.Iterator<E>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicReferenceArray<E> |
currentBuffer |
private int |
mask |
private E |
nextElement |
private long |
nextIndex |
private long |
pIndex |
Constructor and Description |
---|
WeakIterator(java.util.concurrent.atomic.AtomicReferenceArray<E> currentBuffer,
long cIndex,
long pIndex) |
Modifier and Type | Method and Description |
---|---|
private E |
getNext() |
boolean |
hasNext() |
E |
next() |
void |
remove() |
private void |
setBuffer(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer) |
private final long pIndex
private long nextIndex
private E nextElement
private java.util.concurrent.atomic.AtomicReferenceArray<E> currentBuffer
private int mask
WeakIterator(java.util.concurrent.atomic.AtomicReferenceArray<E> currentBuffer, long cIndex, long pIndex)
public void remove()
remove
in interface java.util.Iterator<E>
public boolean hasNext()
hasNext
in interface java.util.Iterator<E>
private void setBuffer(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer)
private E getNext()