#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 89/100, confidence 100/100.
Install
go get github.com/adrianbrad/queue
Package Data
updated May 30, 2026| Latest version | v1.7.0 |
| Imported by | 11 packages |
| Stars | 354 |
| Forks | 15 |
| Last activity | 4 days ago |
| Latest release | v1.7.0 (1 months ago) |
| License | MIT |
| 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 deheap
Package deheap provides a doubly-ended heap (min-max heap).
#5 bokchoy
Simple job queues for Go backed by Redis