为了解决我对goroutines的一些误解,我去了Go playground并运行了以下代码:
package main
import (
"fmt"
)
func other(done chan bool) {
done <- true
go func() {
for {
fmt.Println("Here")
}
}()
}
func main() {
fmt.Println("Hello, playground")
done := make(chan bool)
go other(done)
<-done
fmt.Println("Finished.")
}
正如我所料,Go playground 返回了一个错误:过程花费的时间太长。
这似乎意味着other
中创建的goroutine永远运行。
但是当我在自己的机器上运行相同的代码时,我几乎立即得到以下输出:
Hello, playground.
Finished.
这似乎暗示着other
中的goroutine在主goroutine结束时退出。这是真的吗?还是主 goroutine 完成,而另一个 goroutine 继续在后台运行?
编辑:Go Playground 上的默认 GOMAXPROCS 已更改,现在默认为 8。在"过去"的日子里,它默认为 1
.要获取问题中描述的行为,请使用 runtime.GOMAXPROCS(1)
将其显式设置为 1。
您看到的内容的说明:
在Go Playground上,GOMAXPROCS是1
(证明(。
这意味着一次执行一个 goroutine,如果该 goroutine 没有阻塞,则调度程序不会被迫切换到其他 goroutine。
您的代码(就像每个 Go 应用程序一样(从执行main()
函数(主 goroutine(的 goroutine 开始。它启动另一个执行other()
函数的goroutine,然后从done
通道接收 - 该通道阻塞。因此,调度程序必须切换到另一个goroutine(执行other()
函数(。
在other()
函数中,当您在done
通道上发送值时,这使得当前(other()
(和main
goroutine都可以运行。调度程序选择继续运行other()
,并且自GOMAXPROCS=1
以来,main()
不再继续。现在other()
启动了另一个执行无限循环的goroutine。调度程序选择执行此 goroutine,该例程需要很长时间才能达到阻塞状态,因此main()
不会继续。
然后 Go Playground 沙盒的超时是一种赦免:
过程花费的时间太长
请注意,Go 内存模型仅保证某些事件先于其他事件发生,您无法保证 2 个并发 goroutines 的执行方式。这使得输出不确定。
您不得质疑任何不违反 Go 内存模型的执行顺序。如果您希望执行到达代码中的某些点(以执行某些语句(,则需要显式同步(需要同步 goroutines(。
另请注意,Go Playground 上的输出是缓存的,因此如果您再次运行该应用,它将不会再次运行,而是会立即显示缓存的输出。如果您更改了代码中的任何内容(例如插入空格或注释(,然后再次运行它,它将被编译并再次运行。您会通过增加的响应时间注意到它。使用当前版本(Go 1.6(,您每次都会看到相同的输出。
本地运行(在您的计算机上(:
当您在本地运行它时,GOMAXPROCS
很可能大于 1
,因为它默认为可用的 CPU 内核数(自 Go 1.5 以来(。所以如果你有一个goroutine执行无限循环并不重要,另一个goroutine将同时执行,这将是main()
,当main()
返回时,你的程序终止;它不会等待其他非main
goroutines 完成(参见规范:程序执行(。
另请注意,即使您将GOMAXPROCS
设置为 1
,您的应用程序也很可能会在"短"时间内退出,因为调度程序执行将切换到其他 goroutine,而不仅仅是永远执行无限循环(但是,如上所述,这是不确定的(。当它发生时,它将是main()
例程,因此当main()
完成并返回时,您的应用程序将终止。
在 Go 游乐场上玩您的应用程序:
如前所述,默认情况下,GOMAXPROCS
1
在Go Playground上。但是,允许将其设置为更高的值,例如:
runtime.GOMAXPROCS(2)
如果没有显式同步,执行仍然不确定,但是您将观察到不同的执行顺序和终止而不会遇到超时:
Hello, playground
Here
Here
Here
...
<Here is printed 996 times, then:>
Finished.
在Go Playground上尝试这种变体。
您将在屏幕上看到的是不确定的。或者更准确地说,如果您传递给通道的true
值有任何延迟,您会看到一些"这里"。
但通常 Stdout 是缓冲的,这意味着它不是即时打印的,而是累积的,在达到最大缓冲区大小后,它被打印出来。在您的情况下,在打印"这里"之前,主功能已经完成,因此该过程完成。
经验法则是:main 函数必须处于活动状态,否则所有其他 goroutines 都会被杀死。