Struct Producer 

pub struct Producer<T, const CAPACITY: usize, A>
where
    T: AnyBitPattern,
    A: Allocator,
{ /* private fields */ }

Available on non-crate feature tests_loom only.

The publishing handle of an SPMC broadcast queue.

Created together with its Consumer by new. A Producer is Send but not Sync: at most one thread may publish at a time. To enforce that, the type is neither Clone nor Copy.

Publishing never blocks and never allocates: when the queue is full the oldest slot is overwritten, and any consumer that hasn’t read past that slot will observe a ReadResult::Lapped on its next read.

Implementations

impl<T, const CAPACITY: usize, A> Producer<T, CAPACITY, A>

where T: AnyBitPattern, A: Allocator,

pub fn publish(&self, value: T)

Publishes value into the next slot.

Wait-free. Never blocks, never allocates. If the queue is full, the oldest slot is silently overwritten; consumers that haven’t read past that slot will observe a ReadResult::Lapped on their next try_read.

Examples

use low_latency_data_structures::spmc::{self, ReadResult, new};
use low_latency_data_structures::mem::global::GlobalAllocator;

let (producer, mut consumer) = new::<u64, 16, GlobalAllocator>(
    spmc::Options::global_mlocked(),
);
producer.publish(42);
assert_eq!(consumer.try_read(), ReadResult::Value(42));

Trait Implementations

impl<T, const CAPACITY: usize, A> Debug for Producer<T, CAPACITY, A>

where T: AnyBitPattern, A: Allocator,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, const CAPACITY: usize, A> Send for Producer<T, CAPACITY, A>

where A: Allocator, T: AnyBitPattern + Send, A::Allocation<Slot<T>>: Send,