2

为了解决我对 goroutine 的一些误解,我去了 Go 操场并运行了以下代码

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 出现了一个错误:Process takes too long

这似乎意味着在其中创建的 goroutineother永远运行。

但是当我在自己的机器上运行相同的代码时,我几乎立即得到了这个输出:

Hello, playground.
Finished.

这似乎意味着other当主 goroutine 完成时,里面的 goroutine 退出。这是真的?还是主 goroutine 完成,而另一个 goroutine 继续在后台运行?

4

2 回答 2

3

解释你所看到的:

在 Go Playground 上,GOMAXPROCS1证明)。

这意味着一次执行一个 goroutine,如果该 goroutine 没有阻塞,调度程序不会被迫切换到其他 goroutine。

您的代码(就像每个 Go 应用程序一样)以执行main()函数的 goroutine(主 goroutine)开始。它启动另一个执行该函数的 goroutine other(),然后它从done通道接收 - 阻塞。所以调度器必须切换到另一个goroutine(执行other()函数)。

在你的other()函数中,当你在通道上发送一个值时done,这使得当前 ( other()) 和maingoroutine 都可以运行。调度程序选择继续运行other(),并且因为GOMAXPROCS=1,main()不再继续。现在other()启动另一个执行无限循环的 goroutine。调度程序选择执行这个 goroutine,它需要永远进入阻塞状态,所以main()不会继续。

然后 Go Playground 的沙箱超时作为一个赦免:

过程耗时太长

请注意,Go 内存模型仅保证某些事件在其他事件之前发生,您无法保证如何执行 2 个并发 goroutine。这使得输出不确定。

您不得质疑任何不违反 Go Memory 模型的执行顺序。如果您希望执行到达代码中的某些点(执行某些语句),您需要显式同步(您需要同步您的 goroutines)。

另请注意,Go Playground 上的输出已缓存,因此如果您再次运行该应用程序,它将不会再次运行,而是会立即显示缓存的输出。如果您更改代码中的任何内容(例如插入空格或注释)然后再次运行它,它将被编译并再次运行。您会通过增加的响应时间注意到这一点。使用当前版本(Go 1.6),您每次都会看到相同的输出。

在本地运行(在您的机器上):

当您在本地运行它时,很可能GOMAXPROCS会大于1它默认的可用 CPU 内核数(从 Go 1.5 开始)。因此,如果您有一个 goroutine 执行无限循环并不重要,另一个 goroutine 将同时执行,这将是main(),当main()返回时,您的程序终止;它不会等待其他非maingoroutine 完成(参见规范:程序执行)。

另请注意,即使您设置GOMAXPROCS1,您的应用程序很可能会在“短”时间内退出,因为调度程序实现将切换到其他 goroutine,而不仅仅是永远执行无限循环(但是,如上所述,这是不确定的)。当它完成时,它将成为main()goroutine,因此当main()完成并返回时,您的应用程序将终止。

在 Go Playground 上玩您的应用程序:

如前所述,默认情况下GOMAXPROCS1在 Go Playground 上。但是,可以将其设置为更高的值,例如:

runtime.GOMAXPROCS(2)

如果没有显式同步,执行仍然是不确定的,但是您将观察到不同的执行顺序和终止,而不会遇到超时:

Hello, playground
Here
Here
Here
...
<Here is printed 996 times, then:>
Finished.

在Go Playground上试试这个变体。

于 2016-04-19T00:31:02.093 回答
0

您将在屏幕上看到的内容是不确定的。或者更准确地说,如果true你传递给通道的值被延迟了,你会看到一些“这里”。

但通常 Stdout 是缓冲的,这意味着它不会立即打印,但数据会累积,并在达到最大缓冲区大小后打印。在您的情况下,在打印“这里”之前,主要功能已经完成,因此该过程完成。

经验法则是:main 函数必须是活动的,否则所有其他 goroutine 都会被杀死。

于 2016-04-18T23:13:09.010 回答