queue

Documentation

Index

• type Queue
  • func New() *Queue
  • func (q *Queue) Close()
  • func (q *Queue) IsClose() bool
  • func (q *Queue) Len() int
  • func (q *Queue) Pop() (v interface{})
  • func (q *Queue) Push(v interface{})
  • func (q *Queue) TryPop() (v interface{}, ok bool)
  • func (q *Queue) Wait()

Types

type Queue

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() *Queue

New 创建Queue

func (*Queue) Close

func (q *Queue) Close()

关闭队列

func (*Queue) IsClose

func (q *Queue) IsClose() bool

判断是否已经关闭

func (*Queue) Len

func (q *Queue) Len() int

获取队列长度

func (*Queue) Pop

func (q *Queue) Pop() (v interface{})

Pop 取出队列 （阻塞模式）

func (*Queue) Push

func (q *Queue) Push(v interface{})

Push 放入队列 （非阻塞模式）

func (*Queue) TryPop

func (q *Queue) TryPop() (v interface{}, ok bool)

TryPop 试着取出队列（非阻塞模式）返回ok == false 表示空

func (*Queue) Wait

func (q *Queue) Wait()