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中文網其他相關文章!