Package rx.internal.util.atomic
package rx.internal.util.atomic
-
ClassesClassDescriptionThis is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.A single-producer single-consumer bounded queue with exact capacity tracking.A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.A single-producer single-consumer queue with unbounded capacity.