queue

Documentation

Index

• type Queue
  • func New[T any](consume func(e T)) *Queue[T]
  • func (q *Queue[T]) Close(processRemaining bool)
  • func (q *Queue[T]) Len() int
  • func (q *Queue[T]) Push(e T, priority ...bool)

Types

type Queue

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

Queue implements variable and adaptive size FIFO queue. Unlike channels, never jams

func New

func New[T any](consume func(e T)) *Queue[T]

func (*Queue[T]) Close

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

Close queue must be closed in order to close channels and stop goroutines

func (*Queue[T]) Len

func (q *Queue[T]) Len() int

func (*Queue[T]) Push

func (q *Queue[T]) Push(e T, priority ...bool)

Push places element into the queue optionally with priority