关闭停止通道不会停止goroutines
介绍:
我刚开始学习 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()
}
回答
这段代码在现实生活中运行良好;它只是与游乐场的“假时间”不兼容,因为positive_numbers并且negative_numbers不会阻塞,并且运行时无法决定每个迭代在Sleep到期(基本上,打印需要零模拟挂钟时间,所以他们尝试产生无限输出,并且您在根本没有提前挂钟时间的情况下达到了操场 CPU 使用率限制)。在真实的机器上,你只能在有限的时间内打印有限的输出,你会得到合理的行为。
在操场上,如果你time.Sleep(time.Millisecond)在每次打印后添加类似的东西,你就会迫使假时钟向前移动,程序也会终止。