public final class FloatingCountersSpscConcurrentArrayQueue<E> extends Object implements Queue<E>
Modifier and Type | Field and Description |
---|---|
protected E[] |
buffer |
protected static int |
BUFFER_PAD |
protected int |
capacity |
protected VolatileLongCell |
head |
protected LongCell |
headCache |
protected long |
mask |
protected long |
p00 |
protected long |
p01 |
protected long |
p02 |
protected long |
p03 |
protected long |
p04 |
protected long |
p05 |
protected long |
p06 |
protected long |
p07 |
protected long |
p10 |
protected long |
p11 |
protected long |
p12 |
protected long |
p13 |
protected long |
p14 |
protected long |
p15 |
protected long |
p16 |
protected long |
p17 |
protected long |
p50 |
protected long |
p51 |
protected long |
p52 |
protected long |
p53 |
protected long |
p54 |
protected long |
p55 |
protected long |
p56 |
protected static int |
SPARSE_SHIFT |
protected VolatileLongCell |
tail |
protected LongCell |
tailCache |
Constructor and Description |
---|
FloatingCountersSpscConcurrentArrayQueue(int capacity) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(E e) |
boolean |
addAll(Collection<? extends E> c) |
void |
clear() |
boolean |
contains(Object o) |
boolean |
containsAll(Collection<?> c) |
E |
element() |
boolean |
isEmpty() |
Iterator<E> |
iterator() |
boolean |
offer(E e) |
E |
peek() |
E |
poll() |
E |
remove() |
boolean |
remove(Object o) |
boolean |
removeAll(Collection<?> c) |
boolean |
retainAll(Collection<?> c) |
int |
size() |
Object[] |
toArray() |
<T> T[] |
toArray(T[] a) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
protected long p00
protected long p01
protected long p02
protected long p03
protected long p04
protected long p05
protected long p06
protected long p07
protected long p50
protected long p51
protected long p52
protected long p53
protected long p54
protected long p55
protected long p56
protected static final int BUFFER_PAD
protected static final int SPARSE_SHIFT
protected final int capacity
protected final long mask
protected final E[] buffer
protected final VolatileLongCell tail
protected final VolatileLongCell head
protected final LongCell tailCache
protected final LongCell headCache
protected long p10
protected long p11
protected long p12
protected long p13
protected long p14
protected long p15
protected long p16
protected long p17
public FloatingCountersSpscConcurrentArrayQueue(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>
Copyright © 2013–2017. All rights reserved.