public final class MpmcConcurrentQueueStateMarkers<E> extends Object implements Queue<E>
Modifier and Type | Field and Description |
---|---|
protected E[] |
buffer |
protected int |
capacity |
protected long |
mask |
long |
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 |
p20 |
long |
p21 |
long |
p22 |
long |
p23 |
long |
p24 |
long |
p25 |
long |
p26 |
long |
p30 |
long |
p31 |
long |
p32 |
long |
p33 |
long |
p34 |
long |
p35 |
long |
p36 |
long |
p37 |
long |
p40 |
long |
p41 |
long |
p42 |
long |
p43 |
long |
p44 |
long |
p45 |
long |
p46 |
protected static int |
SIZE_OF_ELEMENT |
Constructor and Description |
---|
MpmcConcurrentQueueStateMarkers(int capacity) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(E e) |
boolean |
addAll(Collection<? extends E> c) |
protected long |
calcOffset(long index) |
protected boolean |
casHead(long expect,
long newValue) |
protected boolean |
casTail(long expect,
long newValue) |
void |
clear() |
boolean |
contains(Object o) |
boolean |
containsAll(Collection<?> c) |
E |
element() |
boolean |
isEmpty() |
Iterator<E> |
iterator() |
protected Object |
lvElement(E[] buffer,
long offset) |
protected long |
lvHead() |
protected long |
lvTail() |
boolean |
offer(E e) |
E |
peek() |
E |
poll() |
E |
remove() |
boolean |
remove(Object o) |
boolean |
removeAll(Collection<?> c) |
boolean |
retainAll(Collection<?> c) |
int |
size() |
protected void |
soElement(E[] buffer,
long offset,
Object e) |
protected void |
spElement(E[] buffer,
long offset,
E e) |
protected void |
svElement(E[] buffer,
long offset,
Object e) |
Object[] |
toArray() |
<T> T[] |
toArray(T[] a) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
public long p40
public long p41
public long p42
public long p43
public long p44
public long p45
public long p46
public long p30
public long p31
public long p32
public long p33
public long p34
public long p35
public long p36
public long p37
public long p20
public long p21
public long p22
public long p23
public long p24
public long p25
public long p26
public long p10
public long p11
public long p12
public long p13
public long p14
public long p15
public long p16
protected static final int SIZE_OF_ELEMENT
protected final int capacity
protected final long mask
protected final E[] buffer
public long p00
public long p01
public long p02
public long p03
public long p04
public long p05
public long p06
public long p07
public MpmcConcurrentQueueStateMarkers(int capacity)
public boolean add(E e)
public int size()
size
in interface Collection<E>
public boolean isEmpty()
isEmpty
in interface Collection<E>
public boolean contains(Object o)
contains
in interface Collection<E>
public Object[] toArray()
toArray
in interface Collection<E>
public <T> T[] toArray(T[] a)
toArray
in interface Collection<E>
public boolean remove(Object o)
remove
in interface Collection<E>
public boolean containsAll(Collection<?> c)
containsAll
in interface Collection<E>
public boolean addAll(Collection<? extends E> c)
addAll
in interface Collection<E>
public boolean removeAll(Collection<?> c)
removeAll
in interface Collection<E>
public boolean retainAll(Collection<?> c)
retainAll
in interface Collection<E>
public void clear()
clear
in interface Collection<E>
protected final long lvHead()
protected final boolean casHead(long expect, long newValue)
protected final long lvTail()
protected final boolean casTail(long expect, long newValue)
protected final long calcOffset(long index)
protected final void spElement(E[] buffer, long offset, E e)
protected final void soElement(E[] buffer, long offset, Object e)
protected final void svElement(E[] buffer, long offset, Object e)
protected final Object lvElement(E[] buffer, long offset)
Copyright © 2013–2022. All rights reserved.