Crate work_queue
source ·Expand description
Concurrent work queue helpers
Structs
Error type indicating a task failed because the queue was dropped before completing the task.
A work queue that processes a configurable number of tasks concurrently, deduplicating work
with the same key.
A clonable handle to the work queue. When all clones of WorkSender are dropped, the queue
will process all remaining requests and terminate its output stream.
Traits
Trait for merging context for work tasks with the same key.
Trait that creates a work future from a key and context.
Functions
Creates an unbounded queue of work tasks that will execute up to
concurrency workers at once.