Skip to content

Initital public release

Compare
Choose a tag to compare
@CelestineKao CelestineKao released this 28 Mar 03:17
· 4 commits to master since this release
ab9b77e

In-memory FIFO queue for concurrent task execution. Used to execute tasks concurrently with optional control (via semaphore) over the max number of tasks running at the same time.

Features:

  • Queue processing summary logging
  • Introspection of failed, retried, and succeeded tasks
  • Task retries (optional)
  • Task execution timeout (optional)
  • Queue processing with semaphore (optional)
  • Batch size control (optional)