rxjava 1.3.8 · rx.internal.util.atomic

Class Summary

Modifier and Type	Class and Description
pack-priv abstract class	AtomicReferenceArrayQueue<E>
pack-priv abstract class	BaseLinkedAtomicQueue<E>
public class	LinkedQueueNode<E>
public class	MpscLinkedAtomicQueue<E> This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.
public class	SpscAtomicArrayQueue<E> A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
public class	SpscExactAtomicArrayQueue< the value type held by this queue T> A single-producer single-consumer bounded queue with exact capacity tracking.
public class	SpscLinkedArrayQueue< the element type, not null T> A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.
public class	SpscLinkedAtomicQueue<E> This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.
public class	SpscUnboundedAtomicArrayQueue< the value type held by this queue T> A single-producer single-consumer queue with unbounded capacity.