Uses of Class
rx.internal.util.SuppressAnimalSniffer
-
Packages that use SuppressAnimalSniffer Package Description rx.internal.schedulers rx.internal.util.unsafe -
-
Uses of SuppressAnimalSniffer in rx.internal.schedulers
Methods in rx.internal.schedulers with annotations of type SuppressAnimalSniffer Modifier and Type Method Description (package private) static void
NewThreadWorker. purgeExecutors()
Purges each registered executor and eagerly evicts shutdown executors. -
Uses of SuppressAnimalSniffer in rx.internal.util.unsafe
Classes in rx.internal.util.unsafe with annotations of type SuppressAnimalSniffer Modifier and Type Class Description (package private) class
BaseLinkedQueue<E>
A base data structure for concurrent linked queues.(package private) class
BaseLinkedQueueConsumerNodeRef<E>
(package private) class
BaseLinkedQueueProducerNodeRef<E>
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 aConcurrentCircularArrayQueue
.(package private) class
MpmcArrayQueueConsumerField<E>
(package private) class
MpmcArrayQueueProducerField<E>
class
MpscLinkedQueue<E>
This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.class
SpmcArrayQueue<E>
(package private) class
SpmcArrayQueueConsumerField<E>
(package private) class
SpmcArrayQueueProducerField<E>
(package private) class
SpmcArrayQueueProducerIndexCacheField<E>
class
SpscArrayQueue<E>
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.(package private) class
SpscArrayQueueConsumerField<E>
(package private) class
SpscArrayQueueProducerFields<E>
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.
-