Go 中緩衝通道的範圍是阻塞的

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