如何安全地关闭延迟块中的通道？

Question

考虑以下示例：package mainimport (    "fmt"    "time")func main() {    ticker := time.NewTicker(2 * time.Second)    done := make(chan bool)    defer func() {        fmt.Println("exiting..")        done <- true        close(done)    }()    go func(ticker *time.Ticker, done chan bool) {        for {            select {            case <-done:                fmt.Println("DONE!")                break            case <-ticker.C:                fmt.Println("TICK!...")            }        }    }(ticker, done)    time.Sleep(7 * time.Second)}等待接收的 goroutine 从未done接收到（我猜）主 goroutine 预先完成。但是，如果我将主 goroutine 的睡眠时间更改为 8 秒，它会收到一条消息；为什么对睡眠时间有这种依赖性？是不是因为有第二个区别让 goroutine 保持活力并且没有足够的时间杀死它？我该如何优雅地杀死 goroutine？

Answer 1

您需要确保 main 在 goroutine 完成之前不会返回。

最简单的方法是使用 WaitGroup：

var wg sync.WaitGroup

defer wg.Wait()

wg.Add(1)

go func() {

    defer wg.Done()

    // …

注意defers是逆序运行的，所以一定要放在defer wg.Wait()之前defer close(done)，否则会死锁。