queue

package

v0.0.2 Latest Latest Go to latest Published: Jan 19, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Queue queue

func New() *Queue

New 创建

func (q *Queue) Close()

Close Queue After close, Pop will return nil without block, and TryPop will return v=nil, ok=True

func (q *Queue) IsClose() bool

IsClose check is closed

func (q *Queue) Len() int

Len 获取队列长度

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

Pop 取出队列,（阻塞模式）

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

Push 插入队列，非阻塞

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

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

func (q *Queue) TryPopTimeout(tm time.Duration) (v interface{}, ok bool)

TryPopTimeout 试着取出队列（塞模式+timeout）返回ok == false 表示超时

func (q *Queue) Wait()

Wait 等待队列消费完成