Struct Sender

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

Sender half of the queue. Safe to share between threads.

Implementations

impl<T, const N: usize> Sender<T, N>

pub fn send(&self, item: T) -> Result<(), T>

Sends an item into the queue. The receive order of sent items is not guaranteed.

Examples found in repository

examples/simple.rs (line 20)

fn main() {
    let (tx, mut rx) = FutexQueue::<u32, 4>::new();
    let now = Instant::now();

    let thread = thread::spawn(move || loop {
        let item = rx.recv();
        println!(
            "{} ms: Received: {}",
            now.elapsed().as_millis(),
            item.value()
        );
    });

    tx.send(1).unwrap();
    tx.send_scheduled(2, now + Duration::from_secs(1)).unwrap();
    tx.send(3).unwrap();
    tx.send_scheduled(4, now + Duration::from_secs(2)).unwrap();

    thread.join().unwrap();
}

pub fn send_scheduled(&self, item: T, instant: Instant) -> Result<(), T>

Puts item into a queue to be received at a specified instant. Receive order is earliest deadline first (after all immediate items).

Examples found in repository

examples/simple.rs (line 21)

fn main() {
    let (tx, mut rx) = FutexQueue::<u32, 4>::new();
    let now = Instant::now();

    let thread = thread::spawn(move || loop {
        let item = rx.recv();
        println!(
            "{} ms: Received: {}",
            now.elapsed().as_millis(),
            item.value()
        );
    });

    tx.send(1).unwrap();
    tx.send_scheduled(2, now + Duration::from_secs(1)).unwrap();
    tx.send(3).unwrap();
    tx.send_scheduled(4, now + Duration::from_secs(2)).unwrap();

    thread.join().unwrap();
}