queue

Documentation

Index

• type Queue
  • func (q *Queue[T]) Dequeue(chunkSize int) []T
  • func (q *Queue[T]) DequeueChunk(chunkSize int, f func(vs []T) error) error
  • func (q *Queue[T]) DequeueChunkContext(ctx context.Context, chunkSize int, f func(vs []T) error) error
  • func (q *Queue[T]) Empty() <-chan struct{}
  • func (q *Queue[T]) Enqueue(vs ...T)
  • func (q *Queue[T]) Len() int

Types

type Queue

type Queue[T any] struct {
	Max int

	DisableRescheduling bool
	// contains filtered or unexported fields
}

func (*Queue[T]) Dequeue

func (q *Queue[T]) Dequeue(chunkSize int) []T

func (*Queue[T]) DequeueChunk

func (q *Queue[T]) DequeueChunk(chunkSize int, f func(vs []T) error) error

func (*Queue[T]) DequeueChunkContext

func (q *Queue[T]) DequeueChunkContext(ctx context.Context, chunkSize int, f func(vs []T) error) error

func (*Queue[T]) Empty

func (q *Queue[T]) Empty() <-chan struct{}

func (*Queue[T]) Enqueue

func (q *Queue[T]) Enqueue(vs ...T)

func (*Queue[T]) Len

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