block

Documentation

Index

• type Option
  • func WithMaxSize(max int) Option
• type Queue
  • func New[T any](opts ...Option) Queue[T]

Types

type Option

type Option func(opt *option)

func WithMaxSize

func WithMaxSize(max int) Option

type Queue

type Queue[T any] interface {
	// Enqueue 添加元素到队列
	// 如果队列已关闭，则返回 false，否则返回 true
	Enqueue(value T) bool

	// Dequeue 获取队列中的所有元素
	// 如果队列中没有元素，则本方法会一直阻塞，直到有元素
	// 如果队列已关闭，则返回 false，否则返回 true
	Dequeue(*[]T) bool

	// Close 关闭队列
	Close()

	// Closed 获取队列是否关闭
	Closed() bool
}

Queue 阻塞队列

func New

func New[T any](opts ...Option) Queue[T]