鉴于此代码:package mainimport ( "fmt" "time")func first(quit chan error) { fmt.Println("1") for { select { case <-quit: fmt.Println("first quits") return default: time.Sleep(20 * time.Millisecond) } }}func second(quit chan error) { fmt.Println("2") for { select { case <-quit: fmt.Println("second quits") return default: time.Sleep(20 * time.Millisecond) } }}func main() { quit := make(chan error) go first(quit) go second(quit) //something happens here, let's just simulate with a sleep time.Sleep(500 * time.Millisecond) close(quit) time.Sleep(500 * time.Millisecond)}似乎正确关闭通道会终止两个独立的 go 例程。我认为通道是 1:1 的通信路径,我首先尝试将一个error写入quit通道,但随后只有一个 go 例程会读取它。所以我一直在阅读各种扇出策略,直到我意识到关闭频道可能会奏效。以这种方式关闭通道是终止独立 go 例程的正确方法吗?
1 回答
qq_花开花谢_0
TA贡献1835条经验 获得超7个赞
从封闭通道读取总是成功的。因此,关闭通道通常用于广播所有从该通道读取已发生事件(超时、取消请求等)的 goroutine。
回答你的问题:测试,关闭通道是让所有 goroutine 知道是时候终止的正确方法。context.Context
取消时就是这样。
- 1 回答
- 0 关注
- 92 浏览
添加回答
举报
0/150
提交
取消