Class SpscChunkedAtomicUnpaddedArrayQueue<E>
- java.lang.Object
-
- java.util.AbstractCollection<E>
-
- java.util.AbstractQueue<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueuePrePad<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueConsumerColdFields<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueConsumerField<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueL2Pad<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueProducerFields<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueProducerColdFields<E>
-
- org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueue<E>
-
- org.jctools.queues.atomic.unpadded.SpscChunkedAtomicUnpaddedArrayQueue<E>
-
- Type Parameters:
E
-
- All Implemented Interfaces:
java.lang.Iterable<E>
,java.util.Collection<E>
,java.util.Queue<E>
,IndexedQueueSizeUtil.IndexedQueue
,MessagePassingQueue<E>
,QueueProgressIndicators
public class SpscChunkedAtomicUnpaddedArrayQueue<E> extends BaseSpscLinkedAtomicUnpaddedArrayQueue<E>
NOTE: This class was automatically generated by org.jctools.queues.atomic.unpadded.JavaParsingAtomicUnpaddedLinkedQueueGenerator which can found in the jctools-build module. The original source file is SpscChunkedArrayQueue.java. An SPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size. The queue grows only when the current chunk is full and elements are not copied on resize, instead a link to the new chunk is stored in the old chunk for the consumer to follow.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.jctools.queues.MessagePassingQueue
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy
-
-
Field Summary
Fields Modifier and Type Field Description private int
maxQueueCapacity
private long
producerQueueLimit
-
Fields inherited from class org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueProducerColdFields
producerBuffer, producerBufferLimit, producerMask
-
Fields inherited from class org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueConsumerColdFields
consumerBuffer, consumerMask
-
Fields inherited from interface org.jctools.queues.MessagePassingQueue
UNBOUNDED_CAPACITY
-
-
Constructor Summary
Constructors Constructor Description SpscChunkedAtomicUnpaddedArrayQueue(int capacity)
SpscChunkedAtomicUnpaddedArrayQueue(int chunkSize, int capacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
capacity()
(package private) boolean
offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
-
Methods inherited from class org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueue
currentConsumerIndex, currentProducerIndex, drain, drain, drain, fill, fill, fill, isEmpty, iterator, linkOldToNew, lvNextArrayAndUnlink, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size, soNext, toString, writeToQueue
-
Methods inherited from class org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueProducerFields
lpProducerIndex, lvProducerIndex, soProducerIndex
-
Methods inherited from class org.jctools.queues.atomic.unpadded.BaseSpscLinkedAtomicUnpaddedArrayQueueConsumerField
lpConsumerIndex, lvConsumerIndex, soConsumerIndex
-
Methods inherited from class java.util.AbstractCollection
contains, containsAll, remove, removeAll, retainAll, toArray, toArray
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.util.Collection
contains, containsAll, equals, hashCode, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArray
-
Methods inherited from interface org.jctools.queues.MessagePassingQueue
clear
-
-
-
-
Method Detail
-
offerColdPath
final boolean offerColdPath(java.util.concurrent.atomic.AtomicReferenceArray<E> buffer, long mask, long pIndex, int offset, E v, MessagePassingQueue.Supplier<? extends E> s)
- Specified by:
offerColdPath
in classBaseSpscLinkedAtomicUnpaddedArrayQueue<E>
-
capacity
public int capacity()
- Returns:
- the capacity of this queue or
MessagePassingQueue.UNBOUNDED_CAPACITY
if not bounded
-
-