Struct Sender 

pub struct Sender<T, const P: usize, const NUM_SEGS_P2: usize> { /* private fields */ }

Blocking MPMC Queue - Multi-Producer Single-Consumer with blocking operations

Type Parameters

• T: The type of elements stored in the queue (must be Copy)
• P: log2 of segment size (default 8 = 256 items/segment)
• NUM_SEGS_P2: log2 of number of segments (default 2 = 4 segments, total capacity ~1024)

Examples

use bop_mpmc::mpsc_blocking::MpscBlocking;
use std::thread;
use std::time::Duration;

let mpsc = MpscBlocking::<i32>::new();

// Producer thread
let mpsc_producer = mpsc.clone();
thread::spawn(move || {
    thread::sleep(Duration::from_millis(100));
    mpsc_producer.push(42).unwrap();
});

// Consumer blocks until item is available
let value = mpsc.pop_blocking().unwrap();
assert_eq!(value, 42);
```ignore

Implementations

impl<T, const P: usize, const NUM_SEGS_P2: usize> Sender<T, P, NUM_SEGS_P2>

pub fn is_closed(&self) -> bool

Check if the queue is closed

pub fn producer_count(&self) -> usize

Get the number of registered producers

pub fn producer_id(&self) -> usize

Get the producer ID for this handle

pub fn try_push(&mut self, value: T) -> Result<(), PushError<T>>

Push a value onto the queue

This will use the thread-local SPSC queue for this producer. If successful, notifies any waiting consumer.

pub fn push_spin(&mut self, value: T) -> Result<(), PushError<T>>

Push a value onto the queue (spins if full)

This will use the thread-local SPSC queue for this producer. If successful, notifies any waiting consumer.

pub fn try_push_n(&mut self, values: &[T]) -> Result<usize, PushError<()>>

Push multiple values in bulk

pub unsafe fn unsafe_try_push(&self, value: T) -> Result<(), PushError<T>>

Push a value onto the queue

This will use the thread-local SPSC queue for this producer. If successful, notifies any waiting consumer.

pub unsafe fn unsafe_try_push_n( &self, values: &[T], ) -> Result<usize, PushError<()>>

Push multiple values in bulk

pub fn close(&mut self) -> bool

Close the queue

After closing, no more items can be pushed. This method will block until all SPSC queues are empty. Wakes any waiting consumer.

Note: This waits for consumer to drain all items from all producer queues.

Trait Implementations

impl<T, const P: usize, const NUM_SEGS_P2: usize> Clone for Sender<T, P, NUM_SEGS_P2>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, const P: usize, const NUM_SEGS_P2: usize> Drop for Sender<T, P, NUM_SEGS_P2>

fn drop(&mut self)

Executes the destructor for this type.