管道模式是一種以並發方式跨階段處理資料的強大方法。每個階段對資料執行不同的操作,然後傳遞到下一個階段。
使用通道來傳遞數據,管道模式在許多情況下可以提高效能。
這個想法真的非常簡單,每個階段都會迭代一個通道,拉取資料直到沒有剩餘。對於每個資料項,該階段都會執行其操作,然後將結果傳遞到輸出通道,最後當輸入通道中沒有更多資料時關閉通道。 關閉通道很重要,這樣下游階段才能知道何時終止
建立一個數字序列,將它們加倍,然後過濾低值,最後將它們列印到控制台。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 | 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():
1 2 3 4 5 6 7 8 | func main() {
input := produce(10)
doubled := double(input)
filtered := filterBelow10(doubled)
print (filtered)
}
|
登入後複製
依照自己的喜好選擇您的風格。
你會在這裡加什麼?請在下面留下您的評論。
謝謝!
這篇文章以及本系列所有文章的程式碼可以在這裡找到
以上是Go 中的管道模式的詳細內容。更多資訊請關注PHP中文網其他相關文章!