#delay #queue #wait #schedule

delay-queue

A concurrent unbounded blocking queue where each element can only be removed when its delay expires

2 unstable releases

Uses old Rust 2015

0.2.0 Dec 23, 2017
0.1.0 Dec 9, 2017

#1176 in Concurrency

43 downloads per month
Used in 2 crates

MIT/Apache

31KB
458 lines

DelayQueue for Rust

Build Status Build status Crates.io docs.rs

A concurrent unbounded blocking queue where each element can only be removed when its delay expires.

Example

extern crate delay_queue;

use std::time::{Duration, Instant};
use std::thread;
use delay_queue::{Delay, DelayQueue};

fn main() {
    let queue: DelayQueue<Delay<&str>> = DelayQueue::new();

    // Clone the queue and move it to the consumer thread
    let mut consumer_queue = queue.clone();
    let consumer_handle = thread::spawn(move || {
        // The pop() will block until an item is available and its delay has expired
        println!("First pop: {}", consumer_queue.pop().value);
        println!("Second pop: {}", consumer_queue.pop().value);
    });

    // Clone the queue and move it to the producer thread
    let mut producer_queue = queue.clone();
    let producer_handle = thread::spawn(move || {
        // This item can only be popped after 3 seconds have passed
        producer_queue.push(Delay::for_duration("3s", Duration::from_secs(3)));

        // This item can be popped immediately
        producer_queue.push(Delay::until_instant("now", Instant::now()));
    });

    consumer_handle.join().unwrap();
    producer_handle.join().unwrap();

    assert!(queue.is_empty());
}

You can run this example with the command cargo run --example basic_usage

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

No runtime deps