A Dramatiq broker that can be used with Amazon SQS.

event orchestration

The `taskqueue` package provides a distributed task queue currently supporting Asynq (built on Redis). It offers a clean, interface-based API for enqueueing, processing, and monitoring background tasks with support for retries, scheduling, priorities, and more.

通用型任务队列, 带并发控制和故障恢复

Docker image for running Python Celery workers with a simple setup, ready for development and testing.

A multi-threaded system where workers retrieve tasks from a shared queue, process them, and save results safely. Demonstrates concurrency management, thread/goroutine coordination, and exception/error handling in Java and Go.

Taskrunner is an asynchronous task queue with Redis Streams backend

Async reminder email flow (Celery + Redis queue)

Fair queue implementation using Redis with work stealing and priority scheduling

Finite State machine based task queue in golang

Golang asynchronous task/job queue with Redis, SQS, IronMQ, and in-memory backends

Convenience wrapper around amqplib.

TaskQueue-Go: A distributed, high-performance task queue library for Go with support for customizable backends and scalable background job processing.

A powerful Go library for concurrent task processing with customizable retry logic and backoff strategies. Enhance your applications with robust and efficient worker pools that handle retries seamlessly.

A highly configurable Go library for rate-limiting, task scheduling, and priority-based execution with retries, backoff, and circuit breaking capabilities.

Simple Crud Project with Slice db

A simple RabbitMQ sample with Java to implement the Stock Trading API

Curlew is a job pool based on a local machine.

Python client side notification center.

Implementing task workflow with celery