Uses of Interface
rx.internal.util.unsafe.MessagePassingQueue
Packages that use MessagePassingQueue
-
Uses of MessagePassingQueue in rx.internal.util.unsafe
Classes in rx.internal.util.unsafe that implement MessagePassingQueueModifier and TypeClassDescriptionclass
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.(package private) class
class
class
A Multi-Producer-Multi-Consumer queue based on aConcurrentCircularArrayQueue
.(package private) class
(package private) class
(package private) class
(package private) class
final class
(package private) class
(package private) class
(package private) class
(package private) class
(package private) class
(package private) class
(package private) class
final class
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.(package private) class
(package private) class
(package private) class
(package private) class
(package private) class
(package private) class