queue

Documentation

Index

• type Queue
  • func NewQueue[T comparable]() *Queue[T]
  • func (q *Queue[T]) AddWeight(item T, weight int) <-chan struct{}
  • func (q *Queue[T]) Get() (T, func(), bool)
  • func (q *Queue[T]) GetOrWaitWithDone(done <-chan struct{}) (T, func(), bool)
  • func (q *Queue[T]) Len() int

Types

type Queue

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

func NewQueue

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

func (*Queue[T]) AddWeight

func (q *Queue[T]) AddWeight(item T, weight int) <-chan struct{}

func (*Queue[T]) Get

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

func (*Queue[T]) GetOrWaitWithDone

func (q *Queue[T]) GetOrWaitWithDone(done <-chan struct{}) (T, func(), bool)

func (*Queue[T]) Len

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