为什么我有一个死锁,即使它包含一个无限循环?
Why do I have a deadlock even though it includes an endless loop?
所以我开始研究 Go,并且对 go routines 着迷。我现在写了一个简单的测试,看看我是否可以在连续打印变量的同时更改它的值。
我现在有以下代码:
package main
import (
"fmt"
"time"
)
func change(c chan float64) float64 {
time.Sleep(2 * time.Second)
return 2.5
}
func main() {
s := 1.1
c := make(chan float64)
go change(c)
s = <-c
for {
fmt.Println(s)
time.Sleep(100 * time.Millisecond)
}
}
不幸的是它以错误结束:
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan receive]:
main.main()
/home/kramer65/repos/go/src/messing_around/main.go:19 +0x7d
exit status 2
我四处寻找,发现这个死锁发生在主函数结束而goroutines还没有结束的时候。但是由于我有一个无限循环,我不知道我的代码还有什么问题。
谁能告诉我这段代码有什么问题,以及如何在不断打印变量的同时更改变量的值?欢迎所有提示!
看来你对channels和go routines有误解
行:
go change(c)
似乎表明函数change
要写入c
。然而,它最终只是在一段时间后返回一个值。
此值 (2.5
) 未在任何地方收到。此外,c
不会写入任何地方。我怀疑您打算将 2.5
写入通道 c
。其语法如下:
c<-2.5
因此,如果您将 change
函数更改为:
func change(c chan float64) {
time.Sleep(2 * time.Second)
c <- 2.5
}
您应该不会再看到死锁了。请注意,我不再返回 float64
。
我做了一个游乐场来确保这一点:https://play.golang.org/p/SgLiUmPpcAZ
评论更新
1.1
将始终被通道的值覆盖。但是,如果您想打印 s
的初始值(如评论中所述),则必须稍微更改流程并使用 select
语句:
package main
import (
"fmt"
"time"
)
func change(c chan float64) {
time.Sleep(2 * time.Second)
c <- 2.5
}
func main() {
s := 1.1
c := make(chan float64)
go change(c)
for {
select {
case s = <-c:
default:
// c isn't ready yet
}
fmt.Println(s)
time.Sleep(100 * time.Millisecond)
}
}
现在您有了 select
语句,您也可以将它与 time.Ticker
一起使用:
ticker := time.NewTicker(100 * time.Millisecond)
for {
select {
case s = <-c:
case <-ticker.C:
fmt.Println(s)
default:
// c isn't ready yet
}
}
所以我开始研究 Go,并且对 go routines 着迷。我现在写了一个简单的测试,看看我是否可以在连续打印变量的同时更改它的值。
我现在有以下代码:
package main
import (
"fmt"
"time"
)
func change(c chan float64) float64 {
time.Sleep(2 * time.Second)
return 2.5
}
func main() {
s := 1.1
c := make(chan float64)
go change(c)
s = <-c
for {
fmt.Println(s)
time.Sleep(100 * time.Millisecond)
}
}
不幸的是它以错误结束:
fatal error: all goroutines are asleep - deadlock!
goroutine 1 [chan receive]:
main.main()
/home/kramer65/repos/go/src/messing_around/main.go:19 +0x7d
exit status 2
我四处寻找,发现这个死锁发生在主函数结束而goroutines还没有结束的时候。但是由于我有一个无限循环,我不知道我的代码还有什么问题。
谁能告诉我这段代码有什么问题,以及如何在不断打印变量的同时更改变量的值?欢迎所有提示!
看来你对channels和go routines有误解
行:
go change(c)
似乎表明函数change
要写入c
。然而,它最终只是在一段时间后返回一个值。
此值 (2.5
) 未在任何地方收到。此外,c
不会写入任何地方。我怀疑您打算将 2.5
写入通道 c
。其语法如下:
c<-2.5
因此,如果您将 change
函数更改为:
func change(c chan float64) {
time.Sleep(2 * time.Second)
c <- 2.5
}
您应该不会再看到死锁了。请注意,我不再返回 float64
。
我做了一个游乐场来确保这一点:https://play.golang.org/p/SgLiUmPpcAZ
评论更新
1.1
将始终被通道的值覆盖。但是,如果您想打印 s
的初始值(如评论中所述),则必须稍微更改流程并使用 select
语句:
package main
import (
"fmt"
"time"
)
func change(c chan float64) {
time.Sleep(2 * time.Second)
c <- 2.5
}
func main() {
s := 1.1
c := make(chan float64)
go change(c)
for {
select {
case s = <-c:
default:
// c isn't ready yet
}
fmt.Println(s)
time.Sleep(100 * time.Millisecond)
}
}
现在您有了 select
语句,您也可以将它与 time.Ticker
一起使用:
ticker := time.NewTicker(100 * time.Millisecond)
for {
select {
case s = <-c:
case <-ticker.C:
fmt.Println(s)
default:
// c isn't ready yet
}
}