在 go 中，通道分为缓冲和非缓冲两种。缓冲通道允许协程间存储数据，发送和接收不会阻塞，但消耗更多内存。非缓冲通道一次只能存储一个值，发送和接收会立即阻塞，同步效果更好。选择通道类型时，需考虑吞吐量、同步和资源消耗等因素。
Go 语言中的通道缓冲与非缓冲：并行通信剖析
在 Go 语言中，通道是一个用来在协程之间安全传输数据的队列。它们分为缓冲和非缓冲两种类型，每种类型都有其独特的特性和用例。
缓冲通道
立即学习“go语言免费学习笔记（深入）”；
缓冲通道允许在发送者和接收者之间存储一定数量的数据，从而避免协程因缓冲区已满或为空而阻塞。当向缓冲通道发送数据时，如果缓冲区已满，发送者将被阻塞，直到有空间可用为止。同样，当从缓冲通道接收数据时，如果缓冲区为空，接收者将被阻塞，直到有数据可用为止。
代码示例：缓冲通道
package main
import (
"fmt"
"sync"
)
func main() {
// 创建一个容量为 5 的缓冲通道
c := make(chan int, 5)
var wg sync.WaitGroup
// 向通道发送 10 个值
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
c <- i
defer wg.Done()
}(i)
}
// 从通道接收 10 个值
for i := 0; i < 10; i++ {
fmt.Println(<-c)
}
wg.Wait()
}在上面的示例中，尽管发送和接收协程同时运行，但由于缓冲通道的缓冲能力，它们不会阻塞。
非缓冲通道
非缓冲通道在任何时候都最多只存储一个值。向非缓冲通道发送数据时，如果接收者没有准备好，发送者将被立即阻塞。同样，当从非缓冲通道接收数据时，如果发送者没有准备好，接收者将被立即阻塞。
代码示例：非缓冲通道
package main
import (
"fmt"
"sync"
)
func main() {
// 创建一个非缓冲通道
c := make(chan int)
var wg sync.WaitGroup
// 向通道发送 10 个值
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
c <- i
defer wg.Done()
}(i)
}
// 从通道接收 10 个值，并强制顺序打印
for i := 0; i < 10; i++ {
<-c
fmt.Println(i)
}
wg.Wait()
}在上面的示例中，发送和接收协程都是交替进行的，因为非缓冲通道的非阻塞特性。
选择缓冲和非缓冲通道
在选择缓冲和非缓冲通道时，需要考虑以下因素：
- 吞吐量：缓冲通道比非缓冲通道提供更高的吞吐量，因为接收者和发送者可以同时运行。
- 同步：非缓冲通道提供更好的同步，因为发送和接收操作只能在接收者和发送者都准备好时才能进行。
- 资源消耗：缓冲通道在内存中占用更多的空间，因为它们必须存储缓冲数据。
根据具体的需求，可以选择最合适的通道类型。
