pqueue

Nov 4, 2024

Changes in this version

+ func AcquireMulti[T any](ctx context.Context, e T, qList ...*Queue[T]) (context.Context, func(), error)

+ type Opts struct

+ Max int

+ Next func(queued, active []*T) int

+ type Queue struct

+ func New[T any](opts Opts[T]) *Queue[T]

+ func (q *Queue[T]) Acquire(ctx context.Context, e T) (func(), error)

+ func (q *Queue[T]) TryAcquire(ctx context.Context, e T) (func(), error)