php小編魚仔在Go語(yǔ)言中，緩沖通道是一種強(qiáng)大且靈活的工具。緩沖通道提供了一種在發(fā)送和接收數(shù)據(jù)之間進(jìn)行同步的機(jī)制，可以控制通信的速度和順序。它的范圍是阻塞的，也就是說(shuō)當(dāng)通道已滿或?yàn)榭諘r(shí)，發(fā)送和接收操作將被阻塞，直到有足夠的空間或數(shù)據(jù)可用。這種機(jī)制可以有效避免并發(fā)程序中的資源競(jìng)爭(zhēng)和死鎖問(wèn)題，提高程序的可靠性和性能。通過(guò)合理使用緩沖通道，開發(fā)者可以更好地控制并發(fā)程序的執(zhí)行流程，提升程序的效率和穩(wěn)定性。
問(wèn)題內(nèi)容
我一定是腦子有問(wèn)題，但是在迭代緩沖通道時(shí)我被阻塞了
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")
登錄后復(fù)制
輸出
1 2
登錄后復(fù)制
這證明了 2 個(gè)源填充了通道（這是最大容量）。
我在這里缺少什么？ never called 是，嗯，從未被調(diào)用。
編輯
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,
})
登錄后復(fù)制
解決方法
循環(huán) for sourceResults := range resultsStream 重復(fù)從通道接收值，直到關(guān)閉。一旦發(fā)送者完成并關(guān)閉通道循環(huán)就會(huì)結(jié)束。
您可以為每個(gè)并行搜索創(chuàng)建新通道，一旦所有工作協(xié)程完成，您就可以關(guān)閉該通道。這將結(jié)束接收器循環(huán)（注意：不要從接收器端關(guān)閉通道，因?yàn)榘l(fā)送者不會(huì)知道并且發(fā)送到關(guān)閉的通道會(huì)導(dǎo)致恐慌）。
