Package | Description |
---|---|
rx.internal.util.unsafe |
Modifier and Type | Class and Description |
---|---|
class |
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.
|
class |
ConcurrentSequencedCircularArrayQueue<E> |
class |
MpmcArrayQueue<E>
A Multi-Producer-Multi-Consumer queue based on a
ConcurrentCircularArrayQueue . |
class |
MpscLinkedQueue<E>
This is a direct Java port of the MPSC algorithm as presented on 1024
Cores by D.
|
class |
SpmcArrayQueue<E> |
class |
SpscArrayQueue<E>
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
|
class |
SpscUnboundedArrayQueue<E> |
class |
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.
|
Copyright © 2018. All rights reserved.