本文是《循序渐进Go语言》的第七篇-Go通道。
上一篇文章中,我们讲了一个goroutine是如何分配、执行的。我们并没有讲解多个goroutine是如何通信的。Go的并发模型CSP,如果缺少了channel, 仅仅有routine是不完美的,也就不能实现高并发间的通信。channel是实现routine间数据共享的关键所在。
1 同步channel
同步channel 分了四种场景。我们分开来看
1.1 发送,接收者队列有等待接受者
1.2 发送,接收者队列没有等待接受者
1.3 接收,发送者队列有等待发送者
1.4 接收,发送者队列没有等待发送者
2 异步channel
异步模式主要是围绕缓冲槽进行。
当有空位时,发送者向槽中复制数据;
有数据后,接受者从槽中获取数据。
另外,双方都有唤醒另外一方的责任。
2.1 发送过程
2.2 接收过程
3 channel关闭
流程很简单,先释放所有接受者,然后释放所有的发送者即可。
4 select的用法
我们来看一段使用select的代码:
func main() {
c1, c2 := make(chan int), make(chan int, 2)
select {
case c1 <- 1:
println(0x11)
case <-c2:
println(0x22)
default:
println(0xff)
}
}
select 的核心流程如下:
5 总结
本文以图表的形式,讲解了同步异步 channel的发送、接收过程,然后讲了close过程,最后讲了select的流程。希望对你有所帮助。
6 参考文献
《Go语言学习笔记》
Go源码
7 其他
本文是《循序渐进go语言》的第七篇-《Go通道channel》。
如果有疑问,可以直接留言,也可以关注公众号 “链人成长chainerup” 提问留言,或者加入知识星球“链人成长” 与我深度链接~
=============================================
channel 文章: https://draveness.me/golang/concurrency/golang-channel.html
select 文章: https://draveness.me/golang/keyword/golang-select.html