queue

type MPSC ¶

type MPSC[T any] struct {
	// contains filtered or unexported fields
}

MPSC is an MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size. The queue grows only when the current buffer is full and elements are not copied on resize, instead a link to the new buffer is stored in the old buffer for the consumer to follow.

func NewMPSC[T any](initialCapacity, maxCapacity uint32) *MPSC[T]

func (m *MPSC[T]) IsEmpty() bool

func (m *MPSC[T]) Size() uint64

func (m *MPSC[T]) TryPop() *T

func (m *MPSC[T]) TryPush(t *T) bool