Struct Drainer 

pub struct Drainer<'ring, T> { /* private fields */ }

Batch-drain handle for a Ring<T>. The ring is multi-consumer, so any number of Drainers (or bare Ring::dequeue callers) may drain the same ring concurrently while producers push — each pop is CAS-linearised on dequeue_pos.

Implementations

impl<'ring, T> Drainer<'ring, T>

pub fn new(ring: &'ring Ring<T>) -> Self

Wrap a ring reference in a drainer.

pub fn drain_into(&mut self, out: &mut [T]) -> usize

Move up to out.len() items out of the ring into out in FIFO order.

Returns the number of items written. Each item is claimed via the multi-consumer Ring::dequeue CAS, so concurrent drainers split the stream without ever reading the same cell; the loop stops at the first empty pop (another consumer may have raced us to the tail).