Uses of Package
rx.internal.util.unsafe
Packages that use rx.internal.util.unsafe
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Classes in rx.internal.util.unsafe used by rx.internal.operatorsClassDescriptionA Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
-
Classes in rx.internal.util.unsafe used by rx.internal.util.unsafeClassDescriptionA base data structure for concurrent linked queues.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.This is a tagging interface for the queues in this library which implement a subset of the
Queue
interface sufficient for concurrent message passing.
Message passing queues offer happens before semantics to messages passed through, namely that writes made by the producer before offering the message are visible to the consuming thread after the message has been polled out of the queue.This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.