queue

Aug 19, 2026

Changes in this version

+ func DeleteFunc[T any](q *BlockingQueue[T], f func(t T) bool)

+ type BlockingQueue struct

+ func NewBlockingQueue[T any](capacity int) *BlockingQueue[T]

+ func (q *BlockingQueue[T]) Dequeue(ctx context.Context) (item T, ok bool)

+ func (q *BlockingQueue[T]) Enqueue(ctx context.Context, item T) bool

+ func (q *BlockingQueue[T]) TryDequeue() (T, bool)

+ func (q *BlockingQueue[T]) TryEnqueue(item T) bool