队列类

Documentation

Overview

包 gqueue 提供动态/静态并发安全队列。

功能：

1.先进先出队列（数据 -> 列表 -> 通道）；

2.快速创建和初始化；

3.支持动态队列大小（无限制的队列大小）；

4.从队列中读取数据时会阻塞。 md5:ff40490071065bb6

Index

• type X结构_队列
  • func X创建(队列长度 ...int) *X结构_队列
  • func (q *X结构_队列) X关闭()
  • func (q *X结构_队列) X加入(值 interface{})
  • func (q *X结构_队列) X取出() interface{}
  • func (q *X结构_队列) X取成员数() (长度 int64)
  • func (q *X结构_队列) X弃用_Size() int64

Types

type X结构_队列

type X结构_队列 struct {
	C chan interface{} // 数据读取的底层通道。 md5:1bf7b6e23c35ba5f
	// contains filtered or unexported fields
}

X结构_队列是一个基于双向链表和通道的并发安全队列。 md5:dc3dd26386e4acfb

func X创建

func X创建(队列长度 ...int) *X结构_队列

X创建 返回一个空的队列对象。 可选参数 `limit` 用于限制队列的大小，默认情况下无限制。 当提供 `limit` 时，队列将变为静态且高性能，其性能可与标准库中的通道相媲美。 md5:9fbd45b8d84f665e

func (*X结构_队列) X关闭

func (q *X结构_队列) X关闭()

X关闭 关闭队列。 注意：它会通知所有因调用Pop方法而阻塞的goroutine立即返回。 md5:bd22bcaaebaed5dc

func (*X结构_队列) X加入

func (q *X结构_队列) X加入(值 interface{})

X加入 将数据 `v` 推入队列。 注意，如果在关闭队列后调用 X加入，它将引发 panic。 md5:ace317b42ed78776

func (*X结构_队列) X取出

func (q *X结构_队列) X取出() interface{}

X取出 从队列中按先进先出（FIFO）方式弹出一个项目。 如果在关闭队列后调用 X取出，它会立即返回 nil。 md5:f632ecf6d87ed4c5

func (*X结构_队列) X取成员数

func (q *X结构_队列) X取成员数() (长度 int64)

X取成员数 返回队列的长度。 请注意，如果使用无限大的队列大小，结果可能不准确，因为有一个异步通道持续读取列表。 md5:b2b860a611742a51

func (*X结构_队列) X弃用_Size

func (q *X结构_队列) X弃用_Size() int64

X弃用_Size是Len的别名。 警告：请改用Len。 md5:25acbbc5f8f37a14