docs/components/container-gqueue-example

[giscus[bot]]

docs/components/container-gqueue-example

使用GoFrame框架中的gqueue组件进行基本的队列操作，包括元素的入队和出队、队列长度的获取以及队列的关闭。详细演示了通过Push和Pop方法管理队列元素，并展示了队列与glist链表的关系，确保在GoFrame框架下高效构建并发安全的程序逻辑。

https://goframe.org.cn/docs/components/container-gqueue-example

[a179916249]

队列bug
q := gqueue.New()
qq := make(chan int, 100000)
for i := 0; i < 11603; i++ {
q.Push(i)
qq <- i
}
fmt.Println(q.Len())
fmt.Println(len(qq))

输出结果
11602
11603

[hametan]

该文档代码该更新了，已经不能跑了（2.9.6）

[hametan]

Queue.Pop新版代码如下：

func main() {
q := gqueue.New()

// 数据生产者，每隔1秒往队列写数据
gtimer.SetInterval(nil, 2*time.Second, func(ctx context.Context) {
	v := gtime.Now().String()
	q.Push(v)
	fmt.Println("Push:", v)
})

// 3秒后关闭队列
gtimer.SetTimeout(nil, 3*time.Second, func(ctx context.Context) {
	q.Close()
})

// 消费者，不停读取队列数据并输出到终端
for {
	if v := q.Pop(); v != nil {
		fmt.Println("Pop:", v)
	} else {
		break
	}
}

}