MPMC Queue

A bounded multi-producer multi-consumer queue implemented in Rust using Mutex + Condvar.

Features

• Blocking push/pop
• Non-blocking try_push/try_pop
• Thread-safe

Example

use mpmc_queue::queue::{BoundedQueue, MpmcQueue};

let q = MpmcQueue::new(2);
q.push(1);
println!("{}", q.pop());

Usage

# Run example
cargo run

# Run tests
cargo test

# Run benchmark
cargo run --bin bench --release