Crate work_queue

source ·
Expand description

Concurrent work queue helpers


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.


Trait for merging context for work tasks with the same key.
Trait that creates a work future from a key and context.


Creates an unbounded queue of work tasks that will execute up to concurrency workers at once.