blocking

Documentation

Index

• type Queue
  • func New[T any](handoff bool) *Queue[T]
  • func (q *Queue[T]) Close()
  • func (q *Queue[T]) Init(handoff bool) *Queue[T]
  • func (q *Queue[T]) Push(v T) bool
  • func (q *Queue[T]) RawPop() (T, bool)
  • func (q *Queue[T]) SharedPop() (T, bool)
  • func (q *Queue[T]) UniquePop() (T, bool)
  • func (q *Queue[T]) Wait()

Types

type Queue

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

func New

func New[T any](handoff bool) *Queue[T]

func (*Queue[T]) Close

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

func (*Queue[T]) Init

func (q *Queue[T]) Init(handoff bool) *Queue[T]

func (*Queue[T]) Push

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

func (*Queue[T]) RawPop

func (q *Queue[T]) RawPop() (T, bool)

func (*Queue[T]) SharedPop

func (q *Queue[T]) SharedPop() (T, bool)

func (*Queue[T]) UniquePop

func (q *Queue[T]) UniquePop() (T, bool)

func (*Queue[T]) Wait

func (q *Queue[T]) Wait()

Wait ensures that all incoming Pushes observe that the queue is closed.