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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitprivate 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()