goFrame的队列gqueue对比channel使用详解 goFrame的队列gqueue对比channel使用

channel
gqueue

概念
使用场景：
代码演示
打印结果
优势
底层实现
阻止进程销毁
运行结果

总结

channel 首先明确一下channel的作用：用于go协程间的通信。
go语言最大的特点就是支持高并发：goroutine和channel是支持高并发的重要组成部分。
单纯地将函数并发执行是没有意义的。函数与函数间需要交换数据才能体现并发执行函数的意义。
如果说 goroutine 是Go程序并发的执行体，channel就是它们之间的连接。channel是可以让一个 goroutine 发送特定值到另一个 goroutine 的通信机制。
另外要明确知道go的并发哲学，铭记这句原则：用通信来共享内存，而不要用共享内存来通信。
在搞清楚channel的作用之后我们再来研究GoFrame框架（下文简称gf）中gqueue的特点。

gqueue
概念
队列 gqueue 动态大小的并发安全队列
gqueue也可以设置为固定大小的队列，固定大小时和标准库channel没区别。
简单来说channel实现的功能gqueue也能实现。

使用场景：
【goFrame的队列gqueue对比channel使用详解】gqueue是并发安全的，常用于多个goroutine数据通信且支持动态队列大小的场景

代码演示

package mainimport ("fmt""github.com/gogf/gf/container/gqueue""github.com/gogf/gf/os/gtimer""time")func main() {//实例化gqueueq := gqueue.New()//数据生产者每隔1秒想队列写入1条数据gtimer.SetInterval(time.Second, func() {nowStr := time.Now().String()q.Push(nowStr)})//3秒后关闭队列gtimer.SetTimeout(time.Second*3, func() {fmt.Println("关闭队列")q.Close()})// 消费者不停的从队列中取值输出到终端中for {if v := q.Pop(); v != nil {fmt.Println("消费者接收：", v)} else {break}}}复制代码

打印结果

文章图片

优势
为什么不用标准库的channel，要用gqueue呢？

gqueue的使用比channel更灵活，channel有队列大小的限制，而gqueue队列支持动态大小
channel的读写性能确实非常高，但是channel创建的时候需要初始化内存，初始化操作效率非常低；而gqueue的创建效率非常高，gqueue是动态创建内存。

底层实现
gqueue的底层实现是基于glist实现动态大小的特性，在队列满或者队列空时读取数据会产生阻塞。
glist是一个并发安全的链接，支持关闭并发安全的特性，当关闭并发安全的特性时和普通链表无异，在存储和读取数据时，不会产生阻塞。

阻止进程销毁
select{}的作用可以阻止进程销毁

package mainimport ("fmt""github.com/gogf/gf/container/gqueue""github.com/gogf/gf/os/gtime""github.com/gogf/gf/os/gtimer""time")func main() {//实例化队列queue := gqueue.New()// 生产者每隔1秒钟向队列写入一条数据gtimer.SetInterval(time.Second, func() {queue.Push(gtime.Now().String())})//消费者常驻内存一直接收生产者的数据for {select {case v := < -queue.C: //C是 chan interface{}if v != nil {fmt.Println("消费者：", v)} else {return}}}}复制代码

运行结果
如下图所示，select{}可以阻止进程销毁，gtimer一直在生产数据，而for循环中的select一直在消费数据。

文章图片

总结以上就是goFrame的gqueue对比channel使用详解的详细内容，通过这篇文章，我们知道了channel的概念和作用。也知道了gqueue的底层实现和特点，以及gqueue和channel的对比。两者各有什么特点，更多关于goFrame gqueue对比channel的资料请关注脚本之家其它相关文章！