queue

Aug 13, 2024

Changes in this version

+ type MpscQueue struct

+ func NewMpscQueue[T any]() *MpscQueue[T]

+ func (q *MpscQueue[T]) IsEmpty() bool

+ func (q *MpscQueue[T]) Len() int64

+ func (q *MpscQueue[T]) Pop() (T, bool)

+ func (q *MpscQueue[T]) Push(value T) bool

Aug 5, 2024

Changes in this version

+ type Queue struct

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

+ func (q *Queue[T]) Cap() int

+ func (q *Queue[T]) Close()

+ func (q *Queue[T]) CloseRemaining() []T

+ func (q *Queue[T]) IsClosed() bool

+ func (q *Queue[T]) IsEmpty() bool

+ func (q *Queue[T]) Len() int

+ func (q *Queue[T]) Pop() (T, bool)

+ func (q *Queue[T]) Push(i T) bool

+ func (q *Queue[T]) Wait() (T, bool)

May 25, 2024

Changes in this version

+ type Unbounded struct

+ func NewUnbounded[T any]() *Unbounded[T]

+ func (q *Unbounded[T]) Cap() int

+ func (q *Unbounded[T]) Close()

+ func (q *Unbounded[T]) CloseRemaining() []T

+ func (q *Unbounded[T]) IsClosed() bool

+ func (q *Unbounded[T]) IsEmpty() bool

+ func (q *Unbounded[T]) Len() int

+ func (q *Unbounded[T]) Pop() (T, bool)

+ func (q *Unbounded[T]) Push(i T) bool

+ func (q *Unbounded[T]) Wait() (T, bool)