Package org.jctools.queues
Class MpscOnSpscFields<E>
- java.lang.Object
-
- java.util.AbstractCollection<E>
-
- java.util.AbstractQueue<E>
-
- org.jctools.queues.MpscOnSpscL0Pad<E>
-
- org.jctools.queues.MpscOnSpscFields<E>
-
- All Implemented Interfaces:
java.lang.Iterable<E>
,java.util.Collection<E>
,java.util.Queue<E>
- Direct Known Subclasses:
MpscOnSpscQueue
abstract class MpscOnSpscFields<E> extends MpscOnSpscL0Pad<E>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
MpscOnSpscFields.ThreadWeakRef
-
Field Summary
Fields Modifier and Type Field 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
-
Fields inherited from class org.jctools.queues.MpscOnSpscL0Pad
b000, b001, b002, b003, b004, b005, b006, b007, b010, b011, b012, b013, b014, b015, b016, b017, b020, b021, b022, b023, b024, b025, b026, b027, b030, b031, b032, b033, b034, b035, b036, b037, b040, b041, b042, b043, b044, b045, b046, b047, b050, b051, b052, b053, b054, b055, b056, b057, b060, b061, b062, b063, b064, b065, b066, b067, b070, b071, b072, b073, b074, b075, b076, b077, b100, b101, b102, b103, b104, b105, b106, b107, b110, b111, b112, b113, b114, b115, b116, b117, b120, b121, b122, b123, b124, b125, b126, b127, b130, b131, b132, b133, b134, b135, b136, b137, b140, b141, b142, b143, b144, b145, b146, b147, b150, b151, b152, b153, b154, b155, b156, b157, b160, b161, b162, b163, b164, b165, b166, b167, b170, b171, b172, b173, b174, b175, b176, b177
-
-
Constructor Summary
Constructors Constructor Description MpscOnSpscFields(int capacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
addQueue(java.util.Queue<E> q)
(package private) int
numberOfQueues()
protected void
removeQueue(java.lang.Object q)
-
Methods inherited from class java.util.AbstractCollection
contains, containsAll, isEmpty, iterator, remove, removeAll, retainAll, size, toArray, toArray, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Field Detail
-
QUEUES_OFFSET
private static final long QUEUES_OFFSET
-
producerQueue
protected final java.lang.ThreadLocal<java.util.Queue<E>> producerQueue
-
refQ
java.lang.ref.ReferenceQueue<java.lang.Thread> refQ
-
queues
protected volatile java.util.Queue<E>[] queues
-
weakRefHolder
private java.util.List<MpscOnSpscFields.ThreadWeakRef> weakRefHolder
-
-
Method Detail
-
addQueue
protected final void addQueue(java.util.Queue<E> q)
-
removeQueue
protected final void removeQueue(java.lang.Object q)
-
numberOfQueues
int numberOfQueues()
-
-