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 重復從通道接收值，直到關閉。一旦發送者完成并關閉通道循環就會結束。
您可以為每個并行搜索創建新通道，一旦所有工作協程完成，您就可以關閉該通道。這將結束接收器循環（注意：不要從接收器端關閉通道，因為發送者不會知道并且發送到關閉的通道會導致恐慌）。
