Go语言Chan应用

Go语言Chan应用

Channel 是 CSP 模式的具体实现，用于多个 goroutine 通讯。其内部实现了同步，确保并发安全。

Channel 是先进先出，线程安全的，多个goroutine同时访问，不需要加锁。

chan 阻塞

我们定义的管道 intChan 容量是5，开启 goroutine 写入10条数据，在写满5条数据时会阻塞，而 read() 每秒会从 intChan 中读取一条，然后write() 再会写入一条数据。

同步模式

默认为同步模式，需要发送和接收配对。否则会被阻塞，直到另一方准备好后被唤醒。

异步模式

异步方式通过判断缓冲区来决定是否阻塞。如果缓冲区已满，发送被阻塞;缓冲区为空，接收被阻塞。

通常情况下，异步 channel 可减少排队阻塞，具备更高的效率。但应该考虑使用指针规避大对象拷贝，将多个元素打包，减小缓冲区大小。

chan 选择

如果需要同时处理多个 channel，可使用 select 语句。它随机选择一个可用 channel 做收发操作，或执行 default case。

用 select 实现超时控制：

在循环中使用 select default case 需要小心，避免形成洪水。

简单工厂模式

用简单工厂模式打包并发任务和 channel。

下一篇：

Go语言WaitGroup------敬请期待！

第十一章 并发编程

看完本文有收获？那就分享给更多人吧