关闭停止通道不会停止 goroutines

Alw*_*uff 5 go go-playground

介绍:

我刚开始学习 Go 语言,已经到了关于并发的课程。

我为自己发明了一个小任务来尝试实现我所学到的关于关闭 goroutines 的知识。

问题:

如果我们关闭频道,case它将始终在select语句中被选中,这是向所有 goroutine 广播取消信号的好方法。

下面我有 2 个 goroutine 和一个quit永远不会收到的频道。

代码超时 Playground

如果我注释掉 defaultgoroutines 中的一部分,那么quit信号就会被接收到。

题:

我真的不明白为什么会发生这种情况以及如何解决它,尽管我正在尝试。
有人可以解释一下是什么问题并提供一些有关如何解决它的建议吗?

package main

import (
    "fmt"
    "sync"
    "time"
)

func positive_numbers(quit chan struct{}, wg *sync.WaitGroup) {
    defer wg.Done()
    i := 1
    for {
        select {
        case <-quit:
            fmt.Println("[+]Quiting...")
            return
        default:
            fmt.Printf("%v ", i)
            i++
        }
    }
}

func negative_numbers(quit chan struct{}, wg *sync.WaitGroup) {
    defer wg.Done()
    i := -1
    for {
        select {
        case <-quit:
            fmt.Println("[-]Quiting...")
            return
        default:
            fmt.Printf("%v ", i)
            i--
        }
    }
}

func main() {
    quit := make(chan struct{})

    wg := sync.WaitGroup{} // so we can wait for all goroutines to finish
    wg.Add(2)

    go positive_numbers(quit, &wg)
    go negative_numbers(quit, &wg)

    go func(quit chan struct{}) {
        defer close(quit)
        time.Sleep(1 * time.Second)
    }(quit)

    wg.Wait()
}
Run Code Online (Sandbox Code Playgroud)

hob*_*bbs 6

这段代码在现实生活中运行良好;它只是与游乐场的“假时间”不兼容,因为positive_numbers并且negative_numbers不会阻塞,并且运行时无法决定每个迭代在Sleep到期(基本上,打印需要零模拟挂钟时间,所以他们尝试产生无限输出,并且您在根本没有提前挂钟时间的情况下达到了操场 CPU 使用率限制)。在真实的机器上,你只能在有限的时间内打印有限的输出,你会得到合理的行为。

在操场上,如果你time.Sleep(time.Millisecond)在每次打印后添加类似的东西,你就会迫使假时钟向前移动,程序也会终止。