」工欲善其事,必先利其器。「—孔子《論語.錄靈公》
首頁 > 程式設計 > Go 中的 Fanin 模式

Go 中的 Fanin 模式

發佈於2024-08-24
瀏覽:821

Fanin Pattern in Go

讓我們來看看扇入模式。當我們需要將來自多個線程的相關資料匯集在一起時,這在 Go 中非常有用。

例如,假設您對不同的服務進行了多次 API 調用,並且需要合併結果。

這是一個非常容易實現的模式,但您確實需要注意如何處理頻道。容易出現死鎖情況。

// produce is used to simulate the different data sources
func produce(id int) chan int {
    ch := make(chan int)
    go func() {
        for i := 0; i 



這裡我們使用 Produce 函數來模擬不同的來源。這些來源通道被傳送到執行組合操作的 fanin 函數。

fanin 函數建立輸出通道,然後啟動一個對每個輸入進行操作的 goroutine。我們使用 WaitGroup 來指示所有輸入來源何時組合到輸出通道。

在這個簡單的範例中,主執行緒只是迭代輸出。請注意,無法保證順序,兩個輸入的值是混合的。

要提出的一個關鍵點是,當我們完成組合輸入時,我們必須關閉輸出通道。一旦通道為空,範圍運算子將無限期等待。註解掉 close(output) 行,您將會看到出現死鎖情況。

我們如何改進這一點?請在下面留言給我。

謝謝!

這篇文章以及本系列所有文章的程式碼可以在這裡找到

版本聲明 本文轉載於:https://dev.to/johnscode/fanin-pattern-in-go-5e5d?1如有侵犯,請聯絡[email protected]刪除
最新教學 更多>

免責聲明: 提供的所有資源部分來自互聯網,如果有侵犯您的版權或其他權益,請說明詳細緣由並提供版權或權益證明然後發到郵箱:[email protected] 我們會在第一時間內為您處理。

Copyright© 2022 湘ICP备2022001581号-3