#1 Asynq
Package asynq provides a framework for Redis based distrubted task queue.
github.com/adrianbrad/queue
queue
Package queue provides multiple thread-safe generic queue implementations.
Decision Signals
Health score 67/100, confidence 80/100.
Install
go get github.com/adrianbrad/queue
Package Data
updated May 28, 2026| Latest version | v1.7.0 |
| Imported by | 11 packages |
| Stars | 0 |
| Forks | 0 |
| Last activity | 1 months ago |
| Latest release | Unknown |
| License | Unknown |
| Known vuln records | 0 |
API Surface
78 symbols| Symbol | Kind | Synopsis |
|---|---|---|
| Blocking | Type | type Blocking struct{} |
| Blocking.Clear | Method | func (bq *Blocking[T]) Clear() []T |
| Blocking.Contains | Method | func (bq *Blocking[T]) Contains(elem T) bool |
| Blocking.Get | Method | func (bq *Blocking[T]) Get() (v T, _ error) |
| Blocking.GetWait | Method | func (bq *Blocking[T]) GetWait() (v T) |
| Blocking.IsEmpty | Method | func (bq *Blocking[T]) IsEmpty() bool |
| Blocking.Iterator | Method | func (bq *Blocking[T]) Iterator() <-chan T |
| Blocking.MarshalJSON | Method | func (bq *Blocking[T]) MarshalJSON() ([]byte, error) |
| Blocking.Offer | Method | func (bq *Blocking[T]) Offer(elem T) error |
| Blocking.OfferWait | Method | func (bq *Blocking[T]) OfferWait(elem T) |
| Blocking.Peek | Method | func (bq *Blocking[T]) Peek() (v T, _ error) |
| Blocking.PeekWait | Method | func (bq *Blocking[T]) PeekWait() T |
Similar Packages
Go Queue Libraries#2 hatchet
🪓 An orchestration engine for background tasks, AI agents, and durable workflows
#3 machinery
Machinery is an asynchronous task queue/job queue based on distributed message passing.
#4 goworker
Package goworker is a Resque-compatible, Go-based background worker.
#5 gocelery
Package gocelery is Celery Distributed Task Queue in Go Celery distributed tasks are used heavily in many python web applications and this library allows you to implement celery workers in Go as well as being able to submit celery tasks in Go.