Package rx.internal.util.unsafe

Interface Summary

Interface

Description

QueueProgressIndicators

This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.
Class Summary

Class

Description

ConcurrentCircularArrayQueue<E>

A concurrent access enabling class used by circular array based queues this class exposes an offset computation method along with differently memory fenced load/store methods into the underlying array.

ConcurrentSequencedCircularArrayQueue<E>

MpmcArrayQueue<E>

A Multi-Producer-Multi-Consumer queue based on a ConcurrentCircularArrayQueue.

MpscLinkedQueue<E>

This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.

Pow2

SpmcArrayQueue<E>

SpscArrayQueue<E>

A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.

SpscLinkedQueue<E>

This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.

SpscUnboundedArrayQueue<E>

UnsafeAccess

All use of this class MUST first check that UnsafeAccess.isUnsafeAvailable() == true otherwise NPEs will happen in environments without "suc.misc.Unsafe" such as Android.