queue

Documentation

Index

• type Queue
  • func (q *Queue[T]) Pop(ctx context.Context) (elem T, err error)
  • func (q *Queue[T]) Push(elem T)

Types

type Queue

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

Queue is a thread-safe queue.

Unlike a Go channel, Queue doesn't have any constraints on how many elements can be in the queue.

func (*Queue[T]) Pop

func (q *Queue[T]) Pop(ctx context.Context) (elem T, err error)

Pop removes the element from the front of the queue and returns it. It blocks if the queue is empty. It returns an error if the passed-in context is canceled.

func (*Queue[T]) Push

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

Push places elem at the back of the queue.