Crate work_queue

Concurrent work queue helpers

Structs

• Closed
  Error type indicating a task failed because the queue was dropped before completing the task.
• WorkQueue
  A work queue that processes a configurable number of tasks concurrently, deduplicating work with the same key.
• WorkSender
  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 concurrency workers at once.