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