Golang併發模式 channel高階使用

再pipeline的情況中，我們通過done來通知goroutine結束。但是，如果我們處理的channel來自系統其它分散的部分，則無法通過done來控制，因為我們不知道資料流終止的時間，此時需要引入or-done機制。or-done機制本質上是對外界資料channel的乙個封裝，以便我們可以實際控制。

給出**示例：

package main
func
main()
)<-
chan
inte***ce)go
func()
select}}
}()return valstream
}}

tee**於linux的tee命令，該模式核心作用是把發來的資料流重新傳送到**中兩個不同的地方。我們傳遞乙個channel，然後返回兩個單獨的channel，用以獲得相同的值。給出**示例：

package main
import
"fmt"
func
main()
, in <-
chan
inte***ce)(
<-
chan
inte***ce
,<-
chan
inte***ce))
out2 :=
make
(chan
inte***ce)go
func()
}}}(
)return out1, out2
}genetor :=
func
(done <-
chan
inte***ce
, n int
)<-
chan
inte***ce)go
func()
}}()
return gench
}done :=
make
(chan
inte***ce
)defer
close
(done)
out1, out2 :=
tee(done,
genetor
(done,10)
)for val1 :=
range out1 
}

扇出扇出模式中，輸入不需要有序。而橋接channel正好與這個相反，該模式適用於輸入有序的情況，及多個資料流的輸入需要有序的獲取。我們必須先處理完乙個channel中的資料，然後才能繼續向下處理，此時可以把這個多個輸入的channel，作為集合單獨放到channel中。

給出**示例：

package main
func
main()
, chanstream <-
chan
<-
chan
inte***ce
)<-
chan
inte***ce)go
func()
select
stream = maybestream
case
<-done:
return
}// ordone機制同樣的，防止外界關閉造成channel無法釋放
for val :=
range
ordone
(done, stream)}}
}()return valstream
}}

Golang併發模式 channel高階使用

Golang併發模式基礎

golang 閒談併發

golang 併發實踐

Golang併發模式 channel高階使用

Golang併發模式基礎

golang 閒談併發

golang 併發實踐

相關推薦