首頁 > 後端開發 > Golang > 主體

Go 中的管道模式

WBOY
發布: 2024-07-29 21:18:20
原創
1020 人瀏覽過

The Pipeline Pattern in Go

管道模式是一種以並發方式跨階段處理資料的強大方法。每個階段對資料執行不同的操作,然後傳遞到下一個階段。

使用通道來傳遞數據,管道模式在許多情況下可以提高效能。

這個想法真的非常簡單,每個階段都會迭代一個通道,拉取資料直到沒有剩餘。對於每個資料項,該階段都會執行其操作,然後將結果傳遞到輸出通道,最後當輸入通道中沒有更多資料時關閉通道。 關閉通道很重要,這樣下游階段才能知道何時終止

建立一個數字序列,將它們加倍,然後過濾低值,最後將它們列印到控制台。

func produce(num int) chan int {
    out := make(chan int)
    go func() {
        for i := 0; i < num; i++ {
            out <- rand.Intn(100)
        }
        close(out)
    }()
    return out
}

func double(input <-chan int) chan int {
    out := make(chan int)
    go func() {
        for value := range input {
            out <- value * 2
        }
        close(out)
    }()
    return out
}

func filterBelow10(input <-chan int) chan int {
    out := make(chan int)
    go func() {
        for value := range input {
            if value > 10 {
                out <- value
            }
        }
        close(out)
    }()
    return out
}

func print(input <-chan int) {
    for value := range input {
        fmt.Printf("value is %d\n", value)
    }
}

func main() {

    print(filterBelow10(double(produce(10))))

}
登入後複製

顯然有一種更容易閱讀的方式來建構 main():

func main() {

    input := produce(10)
        doubled := double(input)
    filtered := filterBelow10(doubled)
    print(filtered)

}
登入後複製

依照自己的喜好選擇您的風格。

你會在這裡加什麼?請在下面留下您的評論。

謝謝!

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

以上是Go 中的管道模式的詳細內容。更多資訊請關注PHP中文網其他相關文章!

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