Class MpscChunkedArrayQueueColdProducerFields<E>
java.lang.Object
java.util.AbstractCollection<E>
java.util.AbstractQueue<E>
org.jctools.queues.BaseMpscLinkedArrayQueuePad1<E>
org.jctools.queues.BaseMpscLinkedArrayQueueProducerFields<E>
org.jctools.queues.BaseMpscLinkedArrayQueuePad2<E>
org.jctools.queues.BaseMpscLinkedArrayQueueConsumerFields<E>
org.jctools.queues.BaseMpscLinkedArrayQueuePad3<E>
org.jctools.queues.BaseMpscLinkedArrayQueueColdProducerFields<E>
org.jctools.queues.BaseMpscLinkedArrayQueue<E>
org.jctools.queues.MpscChunkedArrayQueueColdProducerFields<E>
- All Implemented Interfaces:
Iterable<E>, Collection<E>, Queue<E>, IndexedQueueSizeUtil.IndexedQueue, MessagePassingQueue<E>, QueueProgressIndicators
- Direct Known Subclasses:
MpscChunkedArrayQueue
-
Nested Class Summary
Nested classes/interfaces inherited from interface MessagePassingQueue
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy -
Field Summary
FieldsFields inherited from class BaseMpscLinkedArrayQueueColdProducerFields
producerBuffer, producerMaskFields inherited from class BaseMpscLinkedArrayQueuePad3
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, b177Fields inherited from class BaseMpscLinkedArrayQueueConsumerFields
consumerBuffer, consumerMaskFields inherited from interface MessagePassingQueue
UNBOUNDED_CAPACITY -
Constructor Summary
ConstructorsConstructorDescriptionMpscChunkedArrayQueueColdProducerFields(int initialCapacity, int maxCapacity) -
Method Summary
Methods inherited from class BaseMpscLinkedArrayQueue
availableInQueue, capacity, currentConsumerIndex, currentProducerIndex, drain, drain, drain, fill, fill, fill, getCurrentBufferCapacity, getNextBufferSize, isEmpty, iterator, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size, toStringMethods inherited from class BaseMpscLinkedArrayQueueColdProducerFields
casProducerLimit, lvProducerLimit, soProducerLimitMethods inherited from class BaseMpscLinkedArrayQueueConsumerFields
lpConsumerIndex, lvConsumerIndex, soConsumerIndexMethods inherited from class BaseMpscLinkedArrayQueueProducerFields
casProducerIndex, lvProducerIndex, soProducerIndexMethods inherited from class AbstractCollection
contains, containsAll, remove, removeAll, retainAll, toArray, toArrayMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface Collection
contains, containsAll, equals, hashCode, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArrayMethods inherited from interface MessagePassingQueue
clear
-
Field Details
-
maxQueueCapacity
protected final long maxQueueCapacity
-
-
Constructor Details
-
MpscChunkedArrayQueueColdProducerFields
MpscChunkedArrayQueueColdProducerFields(int initialCapacity, int maxCapacity)
-