channel 分为两种:
1. 无缓冲 channel
2. 缓冲 channel
无缓冲 channel 的使用必须遵循一个原则:推送和读取必须同时存在,否则就发生死锁
先上代码:
这里定义了一个 int 型的信道 c1,然后通过辅助协程并行给 c1 推送 v(就是 i)然后又在主协程读取。
输出:
有缓冲 channel 必须遵循一个原则:要确保 channel 缓冲的个数与推送、读取成比例
输出:
这里定义了一个缓冲区长度为3的 channel,然后推送3条消息,接着循环读取这个 channel,直到 channel 为空。
注意 close(c2)必须有,不然就是死锁,跟上篇文章的死锁情况1是一个道理,close()语句的作用就是告诉计算机我这个 channel 关闭了,不会再接收任何消息啦,故,主携程不会阻塞而发生死锁。
升级一下代码,使用辅助携程实现:
调用:
75行便是使用辅助携程实现给 c3 推送消息
再升级一下,我们用 channel 来实现一个单发单收的队列:
调用:
93行模拟了真实推送情况,每隔2秒推送一个消息,而主携程这里一直在等待,为什么没有死锁?
因为96行 :)
不要通过共享内存来通信,而应该通过通信来共享内存