docs: 单向通道

This commit is contained in:
Shikong 2021-11-18 00:02:35 +08:00
parent 076413d72f
commit d79c328cbb

View File

@ -11,7 +11,7 @@ var wg = new(sync.WaitGroup)
func producer(ch chan<- int) { func producer(ch chan<- int) {
defer wg.Done() defer wg.Done()
for i := 0; i < 100; i++ { for i := 0; i < 200; i++ {
ch <- i ch <- i
} }
@ -31,9 +31,13 @@ func main() {
// 可读可写 双向通道 // 可读可写 双向通道
ch := make(chan int, 10) ch := make(chan int, 10)
wg.Add(2) wg.Add(1)
go producer(ch) go producer(ch)
wg.Add(10)
for i := 0; i < 10; i++ {
go consumer(ch) go consumer(ch)
}
wg.Wait() wg.Wait()
} }