gqueue

May 16, 2024

Changes in this version

+ type BlockingQueue struct

+ C chan T

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

+ func (q *BlockingQueue[T]) Len() (length int64)

+ func (q *BlockingQueue[T]) MustPop() T

+ func (q *BlockingQueue[T]) Pop() (result T, ok bool)

+ func (q *BlockingQueue[T]) Push(v T)

+ func (q *BlockingQueue[T]) Size() int64

+ type RingQueue struct

+ func NewRingQueue[T any](capacity int, safe ...bool) *RingQueue[T]

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

+ func (q *RingQueue[T]) Clear()

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

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

+ func (q *RingQueue[T]) MustPeek() T

+ func (q *RingQueue[T]) MustPop() T

+ func (q *RingQueue[T]) Peek() (x T, ok bool)

+ func (q *RingQueue[T]) Pop() (x T, ok bool)

+ func (q *RingQueue[T]) PopAll() []T

+ func (q *RingQueue[T]) PopMulti(numberOfItems int) []T

+ func (q *RingQueue[T]) Push(x T)

+ func (q *RingQueue[T]) Snapshot(dst []T) []T

Jul 12, 2023

Changes in this version

+ type Queue struct

+ C chan T

+ func New(limit ...int) *Queue[T]

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

+ func (q *Queue[T]) Len() (length int64)

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

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

+ func (q *Queue[T]) Push(v T)

+ func (q *Queue[T]) Size() int64