Package rx.internal.util.atomic

Class Summary

Class

Description

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.