Expand description
Concurrent work queue helpers
Structs§
- Closed
- Error type indicating a task failed because the queue was dropped before completing the task.
- Work
Queue - A work queue that processes a configurable number of tasks concurrently, deduplicating work with the same key.
- Work
Sender - 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§
- TryMerge
- Trait for merging context for work tasks with the same key.
- Work
- Trait that creates a work future from a key and context.
Functions§
- work_
queue - Creates an unbounded queue of work tasks that will execute up to
concurrencyworkers at once.