Package rx.internal.util.atomic
-
Class Summary Class Description AtomicReferenceArrayQueue<E> BaseLinkedAtomicQueue<E> LinkedQueueNode<E> MpscLinkedAtomicQueue<E> This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.SpscAtomicArrayQueue<E> A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.SpscExactAtomicArrayQueue<T> A single-producer single-consumer bounded queue with exact capacity tracking.SpscLinkedArrayQueue<T> A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.SpscLinkedAtomicQueue<E> This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.SpscUnboundedAtomicArrayQueue<T> A single-producer single-consumer queue with unbounded capacity.