Struct QueueProducerHandle 

pub struct QueueProducerHandle<T, I = u32, const N: usize = 0>
where
    T: Copy + Send + Sync + Default,
    I: Copy + Into<u128>,
{ /* private fields */ }

Producer handle for the MPMC queue.

A lightweight, cloneable handle that allows pushing items to the queue. Multiple producer handles can be created for the same queue, enabling multi-producer scenarios. Each clone shares the same underlying queue via Arc.

Type Parameters

• T - The data type to store (must be Copy + Send + Sync + Default)
• I - The index/sequence number type (default: u32)
• N - Compile-time capacity (0 = dynamic, >0 = static)

Examples

use jacques::{owned::queue, traits::QueueProducer};
use std::thread;

let (producer, consumer) = queue::<u64>().capacity(128).channels()?;

// Clone producer for another thread
let producer2 = producer.clone();
let handle = thread::spawn(move || {
    producer2.push(42).unwrap();
});

producer.push(100)?;
handle.join().unwrap();

Trait Implementations

impl<T, I, const N: usize> Clone for QueueProducerHandle<T, I, N>

where T: Copy + Send + Sync + Default, I: Copy + Into<u128>,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T, I, const N: usize> Debug for QueueProducerHandle<T, I, N>

where T: Copy + Send + Sync + Default + Debug, I: Copy + Into<u128> + Debug,

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

Formats the value using the given formatter.

impl<T, I, const N: usize> QueueProducer<T> for QueueProducerHandle<T, I, N>

where T: Copy + Send + Sync + Default, I: Copy + Into<u128>,

fn try_push(&self, value: T) -> Result<(), (T, QueueError)>

Push a value into the queue but does not block if we cannot push it to the queue.

fn push(&self, value: T) -> Result<(), QueueError>

Push a value into the queue.

fn push_with_seq(&self, value: T) -> Result<usize, QueueError>

Push a value and get the sequence number.