Results for delay_queue

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

A simple delay queue for Tokio

Async delay queue backed by async-std and futures-timer

Asynchronous delayed queue for Tokio runtime.

A modern, ergonomic RabbitMQ (AMQP 0-9-1) client for Rust

A single-threaded async executor with EEVDF-based fair scheduling and pluggable task schedulers

Time utils from std::time, tokio::time and tokio_util::time on WASM targets

A Persistent Delayed Queue in Rust

A synchronized thread safe delayed queue

A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.

A behavioral, adaptive sched_ext scheduler with three-tier classification, L2 affinity, and process learning

A copy of tokio-util delay_queue with `Sleep` and `Instant` being replaced with`wasm_timer` equivalents