abstract class MpscOnSpscFields<E> extends MpscOnSpscL0Pad<E>
Modifier and Type | Class and Description |
---|---|
private static class |
MpscOnSpscFields.ThreadWeakRef |
Modifier and Type | Field and Description |
---|---|
protected java.lang.ThreadLocal<java.util.Queue<E>> |
producerQueue |
protected java.util.Queue<E>[] |
queues |
private static long |
QUEUES_OFFSET |
(package private) java.lang.ref.ReferenceQueue<java.lang.Thread> |
refQ |
private java.util.List<MpscOnSpscFields.ThreadWeakRef> |
weakRefHolder |
Constructor and Description |
---|
MpscOnSpscFields(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected void |
addQueue(java.util.Queue<E> q) |
(package private) int |
numberOfQueues() |
protected void |
removeQueue(java.lang.Object q) |
contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
private static final long QUEUES_OFFSET
protected final java.lang.ThreadLocal<java.util.Queue<E>> producerQueue
java.lang.ref.ReferenceQueue<java.lang.Thread> refQ
protected volatile java.util.Queue<E>[] queues
private java.util.List<MpscOnSpscFields.ThreadWeakRef> weakRefHolder
protected final void addQueue(java.util.Queue<E> q)
protected final void removeQueue(java.lang.Object q)
int numberOfQueues()