queue

type MPSC ¶

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

A MPSC is a bounded multi-producer single-consumer concurrent queue.

MPSC instances must be created with NewMPSC function. A MPSC must not be copied after first use.

Based on the data structure from the following C++ library: https://github.com/rigtorp/MPMCQueue

func NewMPSC[T any](capacity int) *MPSC[T]

func (q *MPSC[T]) Capacity() int

func (q *MPSC[T]) Clear()

func (q *MPSC[T]) Insert(item T)

func (q *MPSC[T]) Remove() T