channel 分为两种:

1. 无缓冲 channel

2. 缓冲 channel

无缓冲 channel 的使用必须遵循一个原则:推送和读取必须同时存在,否则就发生死锁

先上代码:

Go 初体验 - channel.1 - 基本用法-LMLPHP

这里定义了一个 int 型的信道 c1,然后通过辅助协程并行给 c1 推送 v(就是 i)然后又在主协程读取。

输出:

Go 初体验 - channel.1 - 基本用法-LMLPHP

有缓冲 channel 必须遵循一个原则:要确保 channel 缓冲的个数与推送、读取成比例

Go 初体验 - channel.1 - 基本用法-LMLPHP

输出:

Go 初体验 - channel.1 - 基本用法-LMLPHP

这里定义了一个缓冲区长度为3的 channel,然后推送3条消息,接着循环读取这个 channel,直到 channel 为空。

注意 close(c2)必须有,不然就是死锁,跟上篇文章的死锁情况1是一个道理,close()语句的作用就是告诉计算机我这个 channel 关闭了,不会再接收任何消息啦,故,主携程不会阻塞而发生死锁。

升级一下代码,使用辅助携程实现:

Go 初体验 - channel.1 - 基本用法-LMLPHP

调用:

Go 初体验 - channel.1 - 基本用法-LMLPHP

75行便是使用辅助携程实现给 c3 推送消息

再升级一下,我们用 channel 来实现一个单发单收的队列:

Go 初体验 - channel.1 - 基本用法-LMLPHP

调用:

Go 初体验 - channel.1 - 基本用法-LMLPHP

93行模拟了真实推送情况,每隔2秒推送一个消息,而主携程这里一直在等待,为什么没有死锁?

因为96行   :)

不要通过共享内存来通信,而应该通过通信来共享内存

05-11 10:57