Go 快速入门指南 - 缓冲通道和非缓冲通道

发布时间：2022-12-23 文章分类：编程知识 投稿人：李佳 字号： 默认 | 大 | 超大 打印

概述

建议先阅读goroutine小节。

Go 箴言: 不要通过共享内存来通信，而要通过通信来共享内存。

goroutine是 Go 程序并发执行的实体，channel (通道)则是它们之间的连接，用于多个goroutine之间互相通信。通道可以让一个goroutine发送特定类型值到另一个goroutine，每一个通道可以发送数据类型称为通道的元素类型。

阻塞通道与非阻塞通道

通过关键字chan+数据类型来表明通道数据类型，调用make()函数来初始化一个通道。make()函数的第二个参数为通道长度，如果未指定或指定为 0，则该通道为非缓存通道 (阻塞通道), 否则该通道为缓存通道 (非阻塞通道)。

阻塞通道

Go 快速入门指南 - 缓冲通道和非缓冲通道

图片来源: https://stackoverflow.com/questions/39826692/what-are-channels-used-for

例子

ch := make(chan string) // 非缓冲通道
ch := make(chan string, 0) // 非缓冲通道
ch := make(chan string, 10) // 缓冲通道, 容量为 10

3 种操作

发送

无缓冲通道上面的发送操作将会阻塞，直到另一个goroutine在对应的通道上面完成接收操作，两个goroutine才可以继续执行。

语法规则

通道变量<-数据
#例如:将变量x发送到通道ch
ch<-x

接收

无缓冲通道上面的接收操作将会阻塞，直到另一个goroutine在对应的通道上面完成发送操作，两个goroutine才可以继续执行。

语法规则

<-通道变量
#例如:从通道ch接收一个值，并且丢弃
<-ch

接收变量<-通道变量
#例如:从通道ch接收一个值，并且赋值给变量x
x:=<-ch

关闭

详情见关闭通道。

例子

搭配 goroutine

packagemain
funcmain(){
ch:=make(chanstring)//没有设置通道的长度
gofunc(){
ch<-"helloworld"
}()
msg:=<-ch//一直阻塞，直到接收到通道消息
println(msg)
}
//$gorunmain.go
//输出如下
/**
helloworld
*/

死锁

packagemain
funcmain(){
ch:=make(chanstring)//没有设置通道的长度
ch<-"helloworld"//向通道发送数据，但是没有接收者
msg:=<-ch//代码执行不到这里,因为上面阻塞发送数据时，就已经死锁了
println(msg)
}
//$gorunmain.go
//输出如下
/**
fatalerror:allgoroutinesareasleep-deadlock!
...
...
exitstatus2
*/

非阻塞通道

Go 快速入门指南 - 缓冲通道和非缓冲通道

图片来源: https://stackoverflow.com/questions/39826692/what-are-channels-used-for

例子

ch:=make(chanstring,10)//缓冲通道,容量为10

3 种操作

发送

语法规则

通道变量<-数据
#例如:将变量x发送到通道ch
ch<-x

接收

语法规则

<-通道变量
#例如:从通道ch接收一个值，并且丢弃
<-ch

接收变量<-通道变量
#例如:从通道ch接收一个值，并且赋值给变量x
x:=<-ch

关闭

详情见关闭通道。

例子

缓存通道容量为 2

packagemain
funcmain(){
ch:=make(chanstring,2)
ch<-"hello"//不会死锁，因为ch是缓冲通道
ch<-"world"
println(<-ch)
println(<-ch)
}
//$gorunmain.go
//输出如下
/**
hello
world
*/

扩展阅读

====

  1. 1.死锁 - 维基百科

联系我

Go 快速入门指南 - 缓冲通道和非缓冲通道

标签 , ,