gqueue

Documentation

Overview

并发安全的动态队列. 优点： 1、队列初始化速度快； 2、可以向队头/队尾进行Push/Pop操作； 3、取数据时如果队列为空那么会阻塞等待；

Index

• type Queue
  • func New(limit ...int) *Queue
  • func (q *Queue) Close()
  • func (q *Queue) PopBack() interface{}
  • func (q *Queue) PopFront() interface{}
  • func (q *Queue) PushBack(v interface{}) error
  • func (q *Queue) PushFront(v interface{}) error
  • func (q *Queue) Size() int

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func New

func New(limit ...int) *Queue

队列大小为非必须参数，默认不限制

func (*Queue) Close

func (q *Queue) Close()

关闭队列(通知所有通过Pop*阻塞的协程退出)

func (*Queue) PopBack

func (q *Queue) PopBack() interface{}

从队尾先进先出地从队列取出一项数据，当没有数据可获取时，阻塞等待

func (*Queue) PopFront

func (q *Queue) PopFront() interface{}

从队头先进先出地从队列取出一项数据，当没有数据可获取时，阻塞等待

func (*Queue) PushBack

func (q *Queue) PushBack(v interface{}) error

将数据压入队列, 队尾

func (*Queue) PushFront

func (q *Queue) PushFront(v interface{}) error

将数据压入队列, 队头

func (*Queue) Size

func (q *Queue) Size() int

获取当前队列大小