通道關閉與廣播 === - 向關閉的channel發送數據,會導致panic - v,ok <-ch;ok為bool,true正常,false通道關閉 - 所有channel接收者都會在channel關閉時,立刻從阻塞等待中返回,ok = false.這個廣播機制常被利用,進行多個訂閱者同時發送信號 ~~~ func TestService(t *testing.T) { dataCh := make(chan int,10) var wg sync.WaitGroup wg.Add(1) go production(dataCh,&wg) wg.Add(1) go consume(dataCh,&wg) wg.Wait() } // 生產者 func production(ch chan int,wg *sync.WaitGroup) { for i:=0;i<1000;i++{ ch<-i } close(ch) wg.Done() } // 消費者 func consume(ch chan int,wg *sync.WaitGroup) { forleep: for { select { case data,ok := <-ch: if ok { fmt.Println(data) }else{ break forleep } } } wg.Done() } ~~~