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 TypeClassDescriptionclassA 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) classclassclassA Multi-Producer-Multi-Consumer queue based on aConcurrentCircularArrayQueue.(package private) class(package private) class(package private) class(package private) classfinal class(package private) class(package private) class(package private) class(package private) class(package private) class(package private) class(package private) classfinal classA 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