Package org.jctools.queues.atomic

Class AtomicQueueUtil

java.lang.Object

org.jctools.queues.atomic.AtomicQueueUtil

final class AtomicQueueUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
AtomicQueueUtil()

Method Summary

Modifier and Type	Method	Description
(package private) static AtomicLongArray	allocateLongArray(int capacity)
(package private) static <E> AtomicReferenceArray<E>	allocateRefArray(int capacity)
(package private) static int	calcCircularLongElementOffset(long index, int mask)
(package private) static int	calcCircularRefElementOffset(long index, long mask)
(package private) static int	calcLongElementOffset(long index)
(package private) static int	calcRefElementOffset(long index)
(package private) static int	length(AtomicReferenceArray<?> buf)
(package private) static long	lpLongElement(AtomicLongArray buffer, int offset)
(package private) static <E> E	lpRefElement(AtomicReferenceArray<E> buffer, int offset)
(package private) static long	lvLongElement(AtomicLongArray buffer, int offset)
(package private) static <E> E	lvRefElement(AtomicReferenceArray<E> buffer, int offset)
(package private) static int	modifiedCalcCircularRefElementOffset(long index, long mask)	This method assumes index is actually (index invalid input: '<'invalid input: '<' 1) because lower bit is used for resize hence the >> 1
(package private) static int	nextArrayOffset(AtomicReferenceArray<?> curr)
(package private) static void	soLongElement(AtomicLongArray buffer, int offset, long e)
(package private) static void	soRefElement(AtomicReferenceArray buffer, int offset, Object value)
(package private) static void	spLongElement(AtomicLongArray buffer, int offset, long e)
(package private) static <E> void	spRefElement(AtomicReferenceArray<E> buffer, int offset, E value)
(package private) static <E> void	svRefElement(AtomicReferenceArray<E> buffer, int offset, E value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AtomicQueueUtil

AtomicQueueUtil()

Method Details

lvRefElement

static <E> E lvRefElement(AtomicReferenceArray<E> buffer,
 int offset)

lpRefElement

static <E> E lpRefElement(AtomicReferenceArray<E> buffer,
 int offset)

spRefElement

static <E> void spRefElement(AtomicReferenceArray<E> buffer,
 int offset,
 E value)

soRefElement

static void soRefElement(AtomicReferenceArray buffer,
 int offset,
 Object value)

svRefElement

static <E> void svRefElement(AtomicReferenceArray<E> buffer,
 int offset,
 E value)

calcRefElementOffset

static int calcRefElementOffset(long index)

calcCircularRefElementOffset

static int calcCircularRefElementOffset(long index,
 long mask)

allocateRefArray

static <E> AtomicReferenceArray<E> allocateRefArray(int capacity)

spLongElement

static void spLongElement(AtomicLongArray buffer,
 int offset,
 long e)

soLongElement

static void soLongElement(AtomicLongArray buffer,
 int offset,
 long e)

lpLongElement

static long lpLongElement(AtomicLongArray buffer,
 int offset)

lvLongElement

static long lvLongElement(AtomicLongArray buffer,
 int offset)

calcLongElementOffset

static int calcLongElementOffset(long index)

calcCircularLongElementOffset

static int calcCircularLongElementOffset(long index,
 int mask)

allocateLongArray

static AtomicLongArray allocateLongArray(int capacity)

length

static int length(AtomicReferenceArray<?> buf)

modifiedCalcCircularRefElementOffset

static int modifiedCalcCircularRefElementOffset(long index,
 long mask)

This method assumes index is actually (index invalid input: '<'invalid input: '<' 1) because lower bit is used for resize hence the >> 1

nextArrayOffset

static int nextArrayOffset(AtomicReferenceArray<?> curr)