Struct BlockingMpmcRing 

pub struct BlockingMpmcRing;

Factory for an MPMC grid of N SPSC rings partitioned across M consumers, every blocking call backed by a cross-process waker.

Implementations

impl BlockingMpmcRing

pub fn create_anon_grid( n_producers: usize, n_consumers: usize, capacity: usize, ) -> Result<(Vec<BlockingMpmcProducer>, Vec<BlockingMpmcConsumer>), BlockingError>

In-process grid: N rings, M consumer subsets, anon-mapped.

pub fn create_grid( path_prefix: impl AsRef<Path>, n_producers: usize, n_consumers: usize, capacity: usize, ) -> Result<(Vec<BlockingMpmcProducer>, Vec<BlockingMpmcConsumer>), BlockingError>

File-backed grid. Path layout: <prefix>.ring.{i}.bin - SPSC ring for producer i <prefix>.pw.{i}.bin - producer-side waker for ring i <prefix>.cw.{m}.bin - consumer-side waker for subset m

pub fn open_grid( path_prefix: impl AsRef<Path>, n_producers: usize, n_consumers: usize, expected_capacity: usize, ) -> Result<(Vec<BlockingMpmcProducer>, Vec<BlockingMpmcConsumer>), BlockingError>

Open an existing file-backed grid.