Go语言中的通道channel详情
作者:酷尔。 发布时间:2024-05-09 09:47:28
标签:Go,通道,channel
一、Go语言通道基础概念
1.channel产生背景
线程之间进行通信的时候,会因为资源的争夺而产生竟态问题,为了保证数据交换的正确性,必须使用互斥量给内存进行加锁,go语言并发的模型是CSP,提倡通过通信共享内存,而不是通过共享内存而实现通信,通道恰巧满足这种需求。
2.channel工作方式
channel
类似与一个队列,满足先进先出的规则,严格保证收发数据的顺序,每一个通道只能通 过固定类型的数据如果通道进行大型结构体、字符串的传输,可以将对应的指针传进去,尽量的节省空间
二、通道使用语法
1.通道的声明与初始化
?? ?//定义一个通道对象使用,其中int可以换为自己需要的类型
?? ?var a chan int ?
?? ?//初始化只有一个位置的通道(第一个参数代表通道类型,第二个参数代表通道有几个位置)
?? ?//位置存满后新的数据将存不进来(阻塞)
?? ?a = make(chan int,1)
2.将数据放入通道内
取出数据使用操作符 <-操作符右是输入变量,操作符左是通道代表数据流入通道内
代码如下:
? ?// 声明一个通道
?? ?var a chan int
?? ??? ?a <- 5
3.从通道内取出数据
取出数据也使用操作符 <-操作符右是通道,操作符左是接受变量
代码如下:
?//声明一个通道类型
?? ?var a chan int
?? ?fmt.Println("未初始化的通道", a)
?? ?a = make(chan int)
?? ?// wg.Add(1)
?? ?go func(a chan int) {
?? ??? ?// defer wg.Done()
?? ??? ?for {
?? ??? ??? ?x := <-a
?? ??? ??? ?fmt.Println("接收到了数据:", x)
?? ??? ?}
?? ?}(a)
4.关闭通道close
如果通道重复关闭或者关闭一个没有初始化的通道就会抛出错误
?close(a)//a为待关闭的通道
在并发函数中一次关闭通道代码如下:
// 互斥锁对象
var once sync.Once
//并发函数
//这个函数的目的是将a通道内数据乘以10发送到通道b内
func f2(a <-chan int, b chan<- int) {
?? ?defer wg.Done()
?? ?for {
?? ??? ?x, ok := <-a
?? ??? ?if !ok {
?? ??? ??? ?break
?? ??? ?}
?? ??? ?fmt.Println(x)
?? ??? ?b <- x * 10
?? ?}
?? ?// 确保b通道只关闭一次
?? ?once.Do(func() {
?? ??? ?close(b)
?? ?})
}
三、单项通道及通道的状态分析
1.单项输出通道
?? ?var b <-chan int
2.单项输入通道
?? ?var b chan<- int
示例函数:
//单项通道一般做函数参数,作为一种规范防止通道混用
//此函数完成的功能是将a内的数据乘以10放入通道b内
func f2(a <-chan int, b chan<- int) {
?? ?for {
?? ??? ?x, ok := <-a
?? ??? ?if !ok {
?? ??? ??? ?break
?? ??? ?}
?? ??? ?fmt.Println(x)
?? ??? ?b <- x * 10
?? ?}
}
3.通道的状态
channel | nil未初始化 | 空通道 | 满通道 | 非空 |
---|---|---|---|---|
接收 | 阻塞 | 阻塞 | 接收值 | 接收值 |
发送 | 阻塞 | 发送值 | 阻塞 | 发送值 |
关闭 | panic | 关闭成功 | 关闭成功 | 关闭成功 |
关闭后返回的数据 | panic | 返回0值 | 数据读完后返回零值 | 数据读完返回零值 |
四、通道死锁原因分析
注意以下情况:
在使用通道的时候,从以上表格可知有时会进入阻塞状态,结合waitGroup,如果在主函数等待使用通道的函数执行结束,而使用通道的函数并且通道陷入阻塞状态,如果有其他函数对其进行唤醒则不会死锁,如果没有其他函数可以对其进行唤醒则会抛出死锁异常。
总结:
通道将数据隔离在每一份通道内,在并发的情况下可以很好的使用数据,当然要熟悉通道阻塞的几种情况,避免死锁异常。
来源:https://blog.csdn.net/apple_51931783/article/details/122532742


猜你喜欢
- argparse介绍 argparse包用于解释命令行参数。这里给出几个常用的方法。# 创建解析器对象# @para: descripti
- 编者注:当讲到了性能优化和案例方面的东西,就要想到如何从开发人员的角度进行了理解,认识SQL是如何执行,以及如何学习高级的SQL,这篇文章对
- Python中可以使用 pickle 模块将对象转化为文件保存在磁盘上,在需要的时候再读取并还原。具体用法如下:pickle是Python库
- 引用起初我会下意识的回答,直接 v == nil 进行判断不就好了吗?然后翻阅了很多资料终于大致搞定里面的道道.例子请看下面这段代码,可以先
- 相信大家对进度条一定不陌生了,比如在我们安装python库的时候可以看到下载的进度,此外在下载文件时也可以看到类似的进度条,比如下图这种:应
- Asp中Server.ScriptTimeOut属性需要注意的一点Server.ScriptTimeout 这个属性给定Asp脚
- // 1.采用计算属性来获取$store中的值computed: { listenstage() {
- 今天,启动MySQL服务器失败,如下所示:[root@spark01 ~]# /etc/init.d/mysqld startStartin
- 很多朋友在留言区询问关于python上传文件和字符到服务器的问题,现编针对这个给大家整理了一个解决办法。上传简单的字符串def send_s
- 继续我们的 Javascript 优化计划,上期已经做到怎么尽可能的缩小 Javascript 脚本的文件体积便于传输。不过这样做仅仅是不够
- os.path.dirname() 获取父目录os.path.basename() #获取文件名或者文件夹名python2缺省为相对路径导入
- 众所周知,Jupyter notebook是一个交互式的Python shell,也就是IPython的封装版,非常适合用来进行数据分析和机
- 起源就在今年9月份,我负责的部门平台项目发布了一个新版本,该版本同时上线了一个新功能,简单说有点类似定时任务。头一天一切正常,但第二天出现了
- 最简单的:<textarea name="A" cols="45" rows="2&
- 背景:有一个爬虫服务,需要定时从公开网站上拉取一些数据,为了避免被识别为爬虫(防爬虫的识别需要根据很多特征,时间仅仅是其中一个维度),需要在
- 有时候我们需要判断某一个IP地址是否属于一个网段,以决定该用户能否访问系统.比如用户登录的IP是218.6.7.7,而我们的程序必须判断他是
- PDO::setAttributePDO::setAttribute — 设置属性(PHP 5 >= 5.1.0, PECL pdo
- 在mysql中limit可以实现快速分页,但是如果数据到了几百万时我们的limit必须优化才能有效的合理的实现分页了,否则可能卡死你的服务器
- 很多用户在网站上会糊弄填写一个电子信箱,请问有什么办法可以阻止这种行为?我们通常用两种方法来进行判断:第一种,设定只有形如aspxhome@
- 一、简介urllib.request.urlopen()函数用于实现对目标url的访问。函数原型如下:urllib.request.urlo