go语言

Go通道channel 与 select

2019-09-19  本文已影响0人  链人成长chainerup

本文是《循序渐进Go语言》的第七篇-Go通道。
上一篇文章中,我们讲了一个goroutine是如何分配、执行的。我们并没有讲解多个goroutine是如何通信的。Go的并发模型CSP,如果缺少了channel, 仅仅有routine是不完美的,也就不能实现高并发间的通信。channel是实现routine间数据共享的关键所在。

1 同步channel

同步channel 分了四种场景。我们分开来看

1.1 发送,接收者队列有等待接受者

发送-有接收者.gif

1.2 发送,接收者队列没有等待接受者

发送-无接收者.gif

1.3 接收,发送者队列有等待发送者

接收-有发送者.gif

1.4 接收,发送者队列没有等待发送者

接收-无发送者.gif

2 异步channel

异步模式主要是围绕缓冲槽进行。
当有空位时,发送者向槽中复制数据;
有数据后,接受者从槽中获取数据。
另外,双方都有唤醒另外一方的责任。

2.1 发送过程

asyncChannel-send.png

2.2 接收过程

asyncChannel-receive.png

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 的核心流程如下:


select.png

5 总结

本文以图表的形式,讲解了同步异步 channel的发送、接收过程,然后讲了close过程,最后讲了select的流程。希望对你有所帮助。

6 参考文献

《Go语言学习笔记》
Go源码

7 其他

本文是《循序渐进go语言》的第七篇-《Go通道channel》。
如果有疑问,可以直接留言,也可以关注公众号 “链人成长chainerup” 提问留言,或者加入知识星球“链人成长” 与我深度链接~

=============================================
channel 文章: https://draveness.me/golang/concurrency/golang-channel.html

channel1.jpeg channel2.jpeg

select 文章: https://draveness.me/golang/keyword/golang-select.html

select1.jpeg select2.jpeg
上一篇 下一篇

猜你喜欢

热点阅读