pack-priv Class MpscGrowableArrayQueue<E>

Additional top-level classes in compilation unit: MpscChunkedArrayQueue, MpscChunkedArrayQueueColdProducerFields, BaseMpscLinkedArrayQueuePad1, BaseMpscLinkedArrayQueueProducerFields, BaseMpscLinkedArrayQueuePad2, BaseMpscLinkedArrayQueueConsumerFields, BaseMpscLinkedArrayQueuePad3, BaseMpscLinkedArrayQueueColdProducerFields, BaseMpscLinkedArrayQueue.

Class Inheritance

extends MpscChunkedArrayQueue<E>

Static Imports

com.github.benmanes.caffeine.cache.Caffeine.ceilingPowerOfTwo

An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size. The queue grows only when the current buffer is full and elements are not copied on resize, instead a link to the new buffer is stored in the old buffer for the consumer to follow.

This is a shaded copy of MpscGrowableArrayQueue provided by JCTools from version 2.0.

Author: [email protected] (Nitsan Wakart)

Field Summary

Inherited from com.github.benmanes.caffeine.cache.MpscChunkedArrayQueue:: p000 p001 p002 p003 p004 p005 p006 p007 p008 p009 p010 p011 p012 p013 p014 p015 p016 p017 p018 p019 p020 p021 p022 p023 p024 p025 p026 p027 p028 p029 p030 p031 p032 p033 p034 p035 p036 p037 p038 p039 p040 p041 p042 p043 p044 p045 p046 p047 p048 p049 p050 p051 p052 p053 p054 p055 p056 p057 p058 p059 p060 p061 p062 p063 p064 p065 p066 p067 p068 p069 p070 p071 p072 p073 p074 p075 p076 p077 p078 p079 p080 p081 p082 p083 p084 p085 p086 p087 p088 p089 p090 p091 p092 p093 p094 p095 p096 p097 p098 p099 p100 p101 p102 p103 p104 p105 p106 p107 p108 p109 p110 p111 p112 p113 p114 p115 p116 p117 p118 p119

Constructor Summary

Access	Constructor and Description
pack-priv	MpscGrowableArrayQueue(int the queue initial capacity. If chunk size is fixed this will be the chunk size. Must be 2 or more. initialCapacity, int 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. maxCapacity)

Method Summary

Modifier and Type	Method and Description
protected long	getCurrentBufferCapacity(long mask) Implements abstract com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.
protected int	getNextBufferSize(E[] buffer) Implements abstract com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getNextBufferSize.

Inherited from com.github.benmanes.caffeine.cache.MpscChunkedArrayQueue:: availableInQueue capacity

Constructor Detail

MpscGrowableArrayQueue	back to summary
pack-priv MpscGrowableArrayQueue(int initialCapacity, int maxCapacity) Parameters initialCapacity:int the queue initial capacity. If chunk size is fixed this will be the chunk size. Must be 2 or more. maxCapacity:int 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.

MpscGrowableArrayQueue

back to summary

pack-priv MpscGrowableArrayQueue(int initialCapacity, int maxCapacity)

Parameters

initialCapacity:int: the queue initial capacity. If chunk size is fixed this will be the chunk size. Must be 2 or more.
maxCapacity:int: 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.

Method Detail

getCurrentBufferCapacity	back to summary
protected long getCurrentBufferCapacity(long mask) Implements abstract com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity. Returns:long Doc from com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity. current buffer capacity for elements (excluding next pointer and jump entry) * 2 Annotations @Override

getCurrentBufferCapacity

back to summary

protected long getCurrentBufferCapacity(long mask)

Implements abstract com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.

Returns:long

Doc from com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getCurrentBufferCapacity.

current buffer capacity for elements (excluding next pointer and jump entry) * 2

Annotations

@Override

getNextBufferSize	back to summary
protected int getNextBufferSize(E[] buffer) Implements abstract com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getNextBufferSize. Returns:int Doc from com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getNextBufferSize. next buffer size(inclusive of next array pointer) Annotations @Override

getNextBufferSize

back to summary

protected int getNextBufferSize(E[] buffer)

Implements abstract com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getNextBufferSize.

Returns:int

Doc from com.github.benmanes.caffeine.cache.BaseMpscLinkedArrayQueue.getNextBufferSize.

next buffer size(inclusive of next array pointer)

Annotations

@Override