首頁 > 後端開發 > Golang > Go 中緩衝通道的範圍是阻塞的

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

WBOY
發布: 2024-02-09 09:42:30
轉載
695 人瀏覽過

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

相關標籤:
來源:stackoverflow.com
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
最新問題
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板