为了账号安全,请及时绑定邮箱和手机立即绑定

关闭通道退出多个 go 例程?

关闭通道退出多个 go 例程?

Go
不负相思意 2022-07-18 15:48:22
鉴于此代码: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取消时就是这样。


查看完整回答
反对 回复 2022-07-18
  • 1 回答
  • 0 关注
  • 92 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信