#fibers #queue #timeout

fibers_timeout_queue

Timeout queue based on fibers crate

1 unstable release

Uses old Rust 2015

0.1.0 Sep 13, 2018

#1915 in Asynchronous

Download history 18/week @ 2023-07-31 26/week @ 2023-08-07 37/week @ 2023-08-14 15/week @ 2023-08-21 20/week @ 2023-08-28 31/week @ 2023-09-04 28/week @ 2023-09-11 17/week @ 2023-09-18 27/week @ 2023-09-25 22/week @ 2023-10-02 20/week @ 2023-10-09 24/week @ 2023-10-16 24/week @ 2023-10-23 28/week @ 2023-10-30 24/week @ 2023-11-06 33/week @ 2023-11-13

113 downloads per month
Used in 2 crates

MIT license

11KB
133 lines

fibers_timeout_queue

Crates.io: fibers_timeout_queue Documentation Build Status Code Coverage License: MIT

This crate provides a timeout queue based on fibers crate.

Documentation

Examples

use fibers_timeout_queue::TimeoutQueue;
use std::time::Duration;
use std::thread;

let mut queue = TimeoutQueue::new();
assert_eq!(queue.pop(), None); // `queue` is empty

queue.push(1, Duration::from_millis(1000));
queue.push(2, Duration::from_millis(100));
queue.push(3, Duration::from_millis(10));
assert_eq!(queue.pop(), None); // No expired items

thread::sleep(Duration::from_millis(50));
assert_eq!(queue.pop(), Some(3)); // There is an expired item
assert_eq!(queue.pop(), None);

Dependencies

~1MB
~18K SLoC