我正在尝试练习 goroutine 和 channel ,我在调用 gorouting 和传递 channel 时遇到问题。 goroutine 将数据推送到 channel 中,然后主线程将打印元素。
我已经使用 for 循环来打印内容但是得到了。
fatal error: all goroutines are asleep - deadlock!
2
1
goroutine 1 [chan receive]:
main.main()
package main
import "fmt"
func smallThread(a int, c chan int) {
c <- a
}
func main() {
c := make(chan int)
go smallThread(1, c)
go smallThread(2, c)
for {
fmt.Println(<-c)
}
}
编辑: 使用 WaitGroup :
func smallThread(a int, c chan int, w *sync.WaitGroup) {
c <- a
w.Done()
}
func main() {
c := make(chan int)
var w sync.WaitGroup
w.Add(2)
go smallThread(1, c, &w)
go smallThread(2, c, &w)
//w.Wait()
for i := range c {
fmt.Println(i)
}
w.Wait()
}
EDIT2:工作代码
func smallThread(a int, c chan int, w *sync.WaitGroup) {
//defer w.Done()
c <- a
w.Done()
}
func main() {
c := make(chan int)
var w sync.WaitGroup
w.Add(1)
go smallThread(1, c, &w)
w.Add(1)
go smallThread(2, c, &w)
go func(c chan int) {
for i := range c {
fmt.Println(i)
}
}(c)
w.Wait()
}
最佳答案
当 goroutines 完成后,关闭 channel 以指示不会添加更多值。收到所有值后,for 循环将中断。
c := make(chan int)
var w sync.WaitGroup
w.Add(2)
go smallThread(1, c, &w)
go smallThread(2, c, &w)
go func() {
w.Wait()
close(c)
}()
for i := range c {
fmt.Println(i)
}
关于go - 使用for循环遍历 channel 时出现Goroutine死锁,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56743291/