public class MpscGrowableArrayQueue<E> extends MpscChunkedArrayQueue<E>
MessagePassingQueue.Consumer<T>, MessagePassingQueue.ExitCondition, MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategyb000, 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, b177maxQueueCapacityproducerBuffer, producerMaskconsumerBuffer, consumerMaskUNBOUNDED_CAPACITY| Constructor and Description |
|---|
MpscGrowableArrayQueue(int maxCapacity) |
MpscGrowableArrayQueue(int initialCapacity,
int maxCapacity) |
| Modifier and Type | Method and Description |
|---|---|
protected long |
getCurrentBufferCapacity(long mask) |
protected int |
getNextBufferSize(E[] buffer) |
availableInQueue, capacitycurrentConsumerIndex, currentProducerIndex, drain, drain, drain, fill, fill, fill, isEmpty, iterator, offer, peek, poll, relaxedOffer, relaxedPeek, relaxedPoll, size, toStringcasProducerLimit, lvProducerLimit, soProducerLimitlpConsumerIndex, lvConsumerIndex, soConsumerIndexcasProducerIndex, lvProducerIndex, soProducerIndexcontains, containsAll, remove, removeAll, retainAll, toArray, toArrayclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitclearpublic MpscGrowableArrayQueue(int maxCapacity)
public MpscGrowableArrayQueue(int initialCapacity,
int maxCapacity)
initialCapacity - the queue initial capacity. If chunk size is fixed this will be the chunk size.
Must be 2 or more.maxCapacity - the maximum capacity will be rounded up to the closest power of 2 and will be the
upper limit of number of elements in this queue. Must be 4 or more and round up to a larger
power of 2 than initialCapacity.protected int getNextBufferSize(E[] buffer)
getNextBufferSize in class MpscChunkedArrayQueue<E>protected long getCurrentBufferCapacity(long mask)
getCurrentBufferCapacity in class MpscChunkedArrayQueue<E>