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

Question

鉴于此代码：

package main

import (

  "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 例程的正确方法吗？

Answer 1

从封闭通道读取总是成功的。因此，关闭通道通常用于广播所有从该通道读取已发生事件（超时、取消请求等）的 goroutine。回答你的问题：测试，关闭通道是让所有 goroutine 知道是时候终止的正确方法。context.Context取消时就是这样。