lockfree

type Queue ¶

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

Queue is a lock-free queue with a single consumer and multiple producers.

func NewQueue[T any]() *Queue[T]

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

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

type YiQueue ¶

type YiQueue[T any] struct {
	Notify chan struct{}
	// contains filtered or unexported fields
}

YiQueue is a lock-free Yielding Queue.

It is desgined to be used by a single consumer and multiple producers. Very little spin-locking is used; instead the ring will notify the consumer with a channel when the write rate is not keeping up with the read rate.

func NewYiQueue[T any]() *YiQueue[T]

func (yq *YiQueue[T]) Iter() iter.Seq[T]

func (yq *YiQueue[T]) Pop() (val T, ok bool)

func (yq *YiQueue[T]) Push(v T)