E - public class SpscGrowableArrayQueue<E> extends BaseSpscLinkedArrayQueue<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy| Modifier and Type | Field and Description |
|---|---|
private long |
lookAheadStep |
private int |
maxQueueCapacity |
producerBuffer, producerBufferLimit, producerMaskb000, 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, b177consumerBuffer, consumerMaskUNBOUNDED_CAPACITY| Constructor and Description |
|---|
SpscGrowableArrayQueue(int capacity) |
SpscGrowableArrayQueue(int chunkSize,
int capacity) |
| Modifier and Type | Method and Description |
|---|---|
private void |
adjustLookAheadStep(int capacity) |
int |
capacity() |
(package private) boolean |
offerColdPath(E[] buffer,
long mask,
long index,
long offset,
E v,
MessagePassingQueue.Supplier<? extends E> s) |
currentConsumerIndex, currentProducerIndex, drain, drain, drain, fill, fill, fill, isEmpty, iterator, linkOldToNew, lvNextArrayAndUnlink, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size, soNext, toString, writeToQueuelpProducerIndex, lvProducerIndex, soProducerIndexlpConsumerIndex, lvConsumerIndex, soConsumerIndexcontains, containsAll, remove, removeAll, retainAll, toArray, toArrayclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitclearprivate final int maxQueueCapacity
private long lookAheadStep
public SpscGrowableArrayQueue(int capacity)
public SpscGrowableArrayQueue(int chunkSize,
int capacity)
final boolean offerColdPath(E[] buffer, long mask, long index, long offset, E v, MessagePassingQueue.Supplier<? extends E> s)
offerColdPath in class BaseSpscLinkedArrayQueue<E>private void adjustLookAheadStep(int capacity)
public int capacity()
MessagePassingQueue.UNBOUNDED_CAPACITY if not bounded