php小编鱼仔在Go语言中，缓冲通道是一种强大且灵活的工具。缓冲通道提供了一种在发送和接收数据之间进行同步的机制，可以控制通信的速度和顺序。它的范围是阻塞的，也就是说当通道已满或为空时，发送和接收操作将被阻塞，直到有足够的空间或数据可用。这种机制可以有效避免并发程序中的资源竞争和死锁问题，提高程序的可靠性和性能。通过合理使用缓冲通道，开发者可以更好地控制并发程序的执行流程，提升程序的效率和稳定性。
我一定是脑子有问题，但是在迭代缓冲通道时我被阻塞了
results := []search.book{}
resultsstream := make(chan []search.book, 2)
defer close(resultsstream)
// parallelize searches to optimize response time
for _, src := range sources {
go src.search(bookname, resultsstream)
}
counter := 0
for sourceresults := range resultsstream {
counter = counter + 1
results = append(results, sourceresults...)
fmt.println(counter)
}
fmt.println("never called")
1 2
这证明了 2 个源填充了通道（这是最大容量）。
我在这里缺少什么？ never called 是，嗯，从未被调用。
var wg sync.WaitGroup
results := []search.Book{}
resultsStream := make(chan []search.Book, len(sources))
defer close(resultsStream)
// parallelize searches to optimize response time
for _, src := range sources {
wg.Add(1)
go src.Search(bookName, resultsStream, &wg)
}
wg.Wait()
close(resultsStream)
for sourceResults := range resultsStream {
results = append(results, sourceResults...)
}
c.JSON(http.StatusOK, gin.H{
"results": results,
})
循环 for sourceResults := range resultsStream 重复从通道接收值，直到关闭。一旦发送者完成并关闭通道循环就会结束。
您可以为每个并行搜索创建新通道，一旦所有工作协程完成，您就可以关闭该通道。这将结束接收器循环（注意：不要从接收器端关闭通道，因为发送者不会知道并且发送到关闭的通道会导致恐慌）。
以上是Go 中缓冲通道的范围是阻塞的的详细内容。更多信息请关注PHP中文网其他相关文章！
