我刚开始学习 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)