goFrame的队列gqueue对比channel使用详解
作者:王中阳Go 发布时间:2024-04-26 17:16:24
channel
首先明确一下channel的作用:用于go协程间的通信。
go语言最大的特点就是支持高并发:goroutine和channel是支持高并发的重要组成部分。
单纯地将函数并发执行是没有意义的。函数与函数间需要交换数据才能体现并发执行函数的意义。
如果说 goroutine 是Go程序并发的执行体,channel
就是它们之间的连接。channel
是可以让一个 goroutine 发送特定值到另一个 goroutine 的通信机制。
另外要明确知道go的并发哲学,铭记这句原则:用通信来共享内存,而不要用共享内存来通信。
在搞清楚channel的作用之后我们再来研究GoFrame框架(下文简称gf)中gqueue的特点。
gqueue
概念
队列 gqueue 动态大小的并发安全队列
gqueue也可以设置为固定大小的队列,固定大小时和标准库channel没区别。
简单来说channel实现的功能gqueue也能实现。
使用场景:
gqueue是并发安全的,常用于多个goroutine数据通信且支持动态队列大小的场景
代码演示
package main
import (
"fmt"
"github.com/gogf/gf/container/gqueue"
"github.com/gogf/gf/os/gtimer"
"time"
)
func main() {
//实例化gqueue
q := 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 main
import (
"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一直在消费数据。
来源:https://juejin.cn/post/7103502362429358116


猜你喜欢
- p>在“服务”中手动启动,显示于是改从控制台启动:然后简单粗暴的找到...\MySQL Server 5.7\新建data文件夹以上所
- GOPATH设置go 命令依赖一个重要的环境变量:$GOPATH1(注:这个不是Go安装目录。下面以笔者的工作目录为说明,请替换自己机器上的
- 本文实例讲述了Python简单实现安全开关文件的两种方式。分享给大家供大家参考,具体如下:以下代码经Python3.3测试。方式1:try:
- 希望这是window.open()打开fullscreen全屏窗口时无提示关闭父窗口的完美解决方案:我们通常都是用控件法,在父窗口文件里放一
- 一、问答平台这个「生活常识解答」机器人采用的是:阿里达摩院发布的语言模型PLUG(最近刚发布的,目前是测试阶段),地址链接如下:https:
- 玩QQ桌球游戏时,有时候用鼠标控制鼠标指针的微小移动比较费劲儿,所以想写个程序,可以用键盘的上下左右键来控制鼠标的移动,每次只移动一个像素。
- 一、开发环境集成开发工具:jupyter notebook 6.5.2集成开发环境:Python 3.10.6第三方库:tensorflow
- 前言本人曾对 Vuex 作过详细介绍,但是今天去回顾的时候发现文章思路有些繁琐,不容易找到重点。于是,在下班前几分钟,我对其重新梳理了一遍。
- 图片的间隙Q:我有一张大图片,把它切割后在Dreamweaver中进行拼接,可是总是有间隙,不知为什么?A:不知你是否把表格的边距、间距和边
- 1.使用测量工具,量化性能才能改进性能,常用的timeit和memory_profiler,此外还有profile、cProfile、hot
- 说明本文根据https://github.com/liuchengxu/blockchain-tutorial的内容,用python实现的,
- 项目功能地图编辑器:可以实现玩家自己定义每一关卡的样式和难易程度运行界面:实现了玩家的移动,跳跃,发射 * ,投掷 * ,以及敌人的AL(移动,
- 最近在项目中出现golang内存溢出的问题,master刚开始运行时只有10多M,运行几天后,竟然达到了10多个G。而且到凌晨流量变少内存也
- ImageEnhance模块提供了一些用于图像增强的类。一、ImageEnhance模块的接口所有的增强类都实现了一个通用的接口,包括一个方
- 一、实现划词功能说是划词翻译,实际上我们是通过获取用户的剪切板内容,通过一系列的操作得到的。首先呢,我们就先实现如何获取剪切板内容的程序首先
- MySQL常用存储引擎之MyISAM特性:1、并发性与锁级别2、表损坏修复check table tablenamerepair table
- 背景:做任务领金币的过程很无聊,而且每天都是重复同样的工作,非常符合自动化的定义;工具:python,appium,Android 手机(我
- 利用python查找电脑里的文件非常方便比如在我的电脑:D:\软件 文件夹里有非常非常多的软件。我忘记某个软件叫什么名字了,只记得文件名称里
- 通过OLE DB for DB2驱动string strSql = @"select phone_no from no_store
- 例题:假设你获取了250部电影的时长(列表a中),希望统计出这些电影时长的分布状态(比如时长为100分钟到120分钟电影的数量,出现的频率)