Package | Description |
---|---|
rx.internal.util.unsafe |
Class and Description |
---|
ConcurrentCircularArrayQueue
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.
|
ConcurrentSequencedCircularArrayQueue |
MessagePassingQueue
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. |
QueueProgressIndicators
This interface is provided for monitoring purposes only and is only available on queues where it is easy to
provide it.
|
Copyright © 2017. All rights reserved.