rsocket-core 1.1.4 · io.rsocket.internal.jctools.queues.UnsafeRefArrayAccess

Modifier and Type	Field and Description
public static final long	REF_ARRAY_BASE
public static final int	REF_ELEMENT_SHIFT

Access	Constructor and Description
pack-priv	UnsafeRefArrayAccess()

Method Summary

Modifier and Type	Method and Description
public static <E> E[]	allocateRefArray(int capacity) This makes for an easier time generating the atomic queues, and removes some warnings.
public static long	Returns: the offset in bytes within the circular array for a given index calcCircularRefElementOffset(long desirable element index index, long (length - 1) mask) Note circular arrays are assumed a power of 2 in length and the `mask` is (length - 1).
public static long	Returns: the offset in bytes within the array for a given index calcRefElementOffset(long desirable element index index)
public static <E> E	Returns: the element at the offset lpRefElement(E[] this.buffer buffer, long computed via `UnsafeRefArrayAccess#calcRefElementOffset(long)` offset) A plain load (no ordering/fences) of an element from a given offset.
public static <E> E	Returns: the element at the offset lvRefElement(E[] this.buffer buffer, long computed via `UnsafeRefArrayAccess#calcRefElementOffset(long)` offset) A volatile load of an element from a given offset.
public static <E> void	soRefElement(E[] this.buffer buffer, long computed via `UnsafeRefArrayAccess#calcCircularRefElementOffset` offset, E an orderly kitty e) An ordered store of an element to a given offset
public static <E> void	spRefElement(E[] this.buffer buffer, long computed via `UnsafeRefArrayAccess#calcRefElementOffset(long)` offset, E an orderly kitty e) A plain store (no ordering/fences) of an element to a given offset

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

REF_ARRAY_BASE	back to summary
public static final long REF_ARRAY_BASE

REF_ELEMENT_SHIFT	back to summary
public static final int REF_ELEMENT_SHIFT

UnsafeRefArrayAccess	back to summary
pack-priv UnsafeRefArrayAccess()

Method Detail

allocateRefArray	back to summary
public static <E> E[] allocateRefArray(int capacity) This makes for an easier time generating the atomic queues, and removes some warnings. Annotations @SuppressWarnings:unchecked

allocateRefArray

back to summary

public static <E> E[] allocateRefArray(int capacity)

This makes for an easier time generating the atomic queues, and removes some warnings.

Annotations

@SuppressWarnings:unchecked

calcCircularRefElementOffset	back to summary
public static long calcCircularRefElementOffset(long index, long mask) Note circular arrays are assumed a power of 2 in length and the `mask` is (length - 1). Parameters index:long desirable element index mask:long (length - 1) Returns:long the offset in bytes within the circular array for a given index

calcCircularRefElementOffset

back to summary

public static long calcCircularRefElementOffset(long index, long mask)

Note

circular arrays are assumed a power of 2 in length and the `mask` is (length - 1).

Parameters

index:long: desirable element index
mask:long: (length - 1)

Returns:long

the offset in bytes within the circular array for a given index

calcRefElementOffset	back to summary
public static long calcRefElementOffset(long index) Parameters index:long desirable element index Returns:long the offset in bytes within the array for a given index

lpRefElement back to summary

lpRefElement	back to summary
public static <E> E lpRefElement(E[] buffer, long offset) A plain load (no ordering/fences) of an element from a given offset. Parameters buffer:E[] this.buffer offset:long computed via `UnsafeRefArrayAccess#calcRefElementOffset(long)` Returns:E the element at the offset Annotations @SuppressWarnings:unchecked

public static <E> E lpRefElement(E[] buffer, long offset)

A plain load (no ordering/fences) of an element from a given offset.

Parameters

buffer:E[]: this.buffer
offset:long: computed via UnsafeRefArrayAccess#calcRefElementOffset(long)

Returns:E

the element at the offset

Annotations

@SuppressWarnings:unchecked

lvRefElement back to summary

lvRefElement	back to summary
public static <E> E lvRefElement(E[] buffer, long offset) A volatile load of an element from a given offset. Parameters buffer:E[] this.buffer offset:long computed via `UnsafeRefArrayAccess#calcRefElementOffset(long)` Returns:E the element at the offset Annotations @SuppressWarnings:unchecked

public static <E> E lvRefElement(E[] buffer, long offset)

A volatile load of an element from a given offset.

Parameters

buffer:E[]: this.buffer
offset:long: computed via UnsafeRefArrayAccess#calcRefElementOffset(long)

Returns:E

the element at the offset

Annotations

@SuppressWarnings:unchecked

soRefElement back to summary

soRefElement	back to summary
public static <E> void soRefElement(E[] buffer, long offset, E e) An ordered store of an element to a given offset Parameters buffer:E[] this.buffer offset:long computed via `UnsafeRefArrayAccess#calcCircularRefElementOffset` e:E an orderly kitty

public static <E> void soRefElement(E[] buffer, long offset, E e)

An ordered store of an element to a given offset

Parameters

buffer:E[]: this.buffer
offset:long: computed via UnsafeRefArrayAccess#calcCircularRefElementOffset
e:E: an orderly kitty

spRefElement back to summary

spRefElement	back to summary
public static <E> void spRefElement(E[] buffer, long offset, E e) A plain store (no ordering/fences) of an element to a given offset Parameters buffer:E[] this.buffer offset:long computed via `UnsafeRefArrayAccess#calcRefElementOffset(long)` e:E an orderly kitty

public static <E> void spRefElement(E[] buffer, long offset, E e)

A plain store (no ordering/fences) of an element to a given offset

Parameters

buffer:E[]: this.buffer
offset:long: computed via UnsafeRefArrayAccess#calcRefElementOffset(long)
e:E: an orderly kitty

pack-priv final Class UnsafeRefArrayAccess

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail