Go Playground 和我机器上的 Go 之间存在差异?
Discrepancies between Go Playground and Go on my machine?
为了解决我对 goroutines 的一些误解,我去了 Go 操场 运行 this code:
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 在后台继续 运行?
您将在屏幕上看到的内容是不确定的。或者更准确地说,如果您传递给 channel 的 true
值有任何延迟,您会看到一些 "Here".
但通常 Stdout 是缓冲的,这意味着它不会立即打印,但数据会累积,在达到最大缓冲区大小后打印。在您的情况下,在打印 "here" 之前,主要功能已经完成,因此过程结束。
经验法则是:main 函数必须存活,否则所有其他 goroutine 都会被杀死。
编辑: Go Playground 上的默认 GOMAXPROCS 已更改,现在默认为 8。在“过去”的日子里,它默认为 1
。要获得问题中描述的行为,请使用 runtime.GOMAXPROCS(1)
.
将其明确设置为 1
对所见内容的解释:
在游乐场上,GOMAXPROCS is 1
(proof)。
这意味着一次执行一个 goroutine,如果那个 goroutine 没有阻塞,调度程序不会被迫切换到其他 goroutine。
您的代码(就像每个 Go 应用程序一样)以执行 main()
函数(主协程)的协程开始。它启动另一个执行 other()
函数的 goroutine,然后它从 done
通道接收数据——这会阻塞。所以调度器必须切换到另一个goroutine(执行other()
函数)。
在你的 other()
函数中,当你在 done
通道上发送一个值时,这使得当前 (other()
) 和 main
goroutine 运行启用。调度器选择继续运行other()
,由于GOMAXPROCS=1
,main()
没有继续。现在 other()
启动另一个执行无限循环的 goroutine。调度程序选择执行这个 goroutine,它需要永远进入阻塞状态,所以 main()
不会继续。
然后 Go Playground 的沙箱超时作为一个赦免:
process took too long
请注意,Go Memory Model 仅保证某些事件在其他事件之前发生,您无法保证 2 个并发 goroutines 如何执行。这使得输出不确定。
任何不违反Go内存模型的执行顺序你都不要质疑。如果你希望执行到代码中的某些点(执行某些语句),你需要显式同步(你需要同步你的 goroutines)。
另请注意,Go Playground 上的输出已缓存,因此如果您再次 运行 应用程序,它不会再次 运行,而是会立即显示缓存的输出.如果您更改代码中的任何内容(例如插入 space 或注释)然后您再次 运行 它,它将被编译并再次 运行 。您会通过增加的响应时间注意到它。使用当前版本 (Go 1.6),您每次都会看到相同的输出。
运行 本地(在您的机器上):
当你在本地 运行 时,很可能 GOMAXPROCS
会大于 1
因为它默认为可用的 CPU 内核数(自 Go 1.5 起) .所以如果你有一个goroutine执行死循环也没关系,另一个goroutine会同时执行,就是main()
,当main()
returns,你的程序终止;它不会等待其他非 main
goroutines 完成(参见 Spec: Program execution)。
另请注意,即使您将 GOMAXPROCS
设置为 1
,您的应用程序也很可能会在“短”时间内退出,因为调度程序实施将切换到其他 goroutine,而不仅仅是执行永远无限循环(但是,如上所述,这是不确定的)。当它完成时,它将是 main()
goroutine,因此当 main()
完成并且 returns 时,您的应用程序终止。
在 Go Playground 上使用您的应用:
如前所述,默认情况下 GOMAXPROCS
在 Go Playground 上是 1
。但是允许将其设置为更高的值,例如:
runtime.GOMAXPROCS(2)
没有显式同步,执行仍然是不确定的,但是您会观察到不同的执行顺序和终止,而不会 运行 进入超时:
Hello, playground
Here
Here
Here
...
<Here is printed 996 times, then:>
Finished.
在 Go Playground 上试试这个变体。
为了解决我对 goroutines 的一些误解,我去了 Go 操场 运行 this code:
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 在后台继续 运行?
您将在屏幕上看到的内容是不确定的。或者更准确地说,如果您传递给 channel 的 true
值有任何延迟,您会看到一些 "Here".
但通常 Stdout 是缓冲的,这意味着它不会立即打印,但数据会累积,在达到最大缓冲区大小后打印。在您的情况下,在打印 "here" 之前,主要功能已经完成,因此过程结束。
经验法则是:main 函数必须存活,否则所有其他 goroutine 都会被杀死。
编辑: Go Playground 上的默认 GOMAXPROCS 已更改,现在默认为 8。在“过去”的日子里,它默认为 1
。要获得问题中描述的行为,请使用 runtime.GOMAXPROCS(1)
.
对所见内容的解释:
在游乐场上,GOMAXPROCS is 1
(proof)。
这意味着一次执行一个 goroutine,如果那个 goroutine 没有阻塞,调度程序不会被迫切换到其他 goroutine。
您的代码(就像每个 Go 应用程序一样)以执行 main()
函数(主协程)的协程开始。它启动另一个执行 other()
函数的 goroutine,然后它从 done
通道接收数据——这会阻塞。所以调度器必须切换到另一个goroutine(执行other()
函数)。
在你的 other()
函数中,当你在 done
通道上发送一个值时,这使得当前 (other()
) 和 main
goroutine 运行启用。调度器选择继续运行other()
,由于GOMAXPROCS=1
,main()
没有继续。现在 other()
启动另一个执行无限循环的 goroutine。调度程序选择执行这个 goroutine,它需要永远进入阻塞状态,所以 main()
不会继续。
然后 Go Playground 的沙箱超时作为一个赦免:
process took too long
请注意,Go Memory Model 仅保证某些事件在其他事件之前发生,您无法保证 2 个并发 goroutines 如何执行。这使得输出不确定。
任何不违反Go内存模型的执行顺序你都不要质疑。如果你希望执行到代码中的某些点(执行某些语句),你需要显式同步(你需要同步你的 goroutines)。
另请注意,Go Playground 上的输出已缓存,因此如果您再次 运行 应用程序,它不会再次 运行,而是会立即显示缓存的输出.如果您更改代码中的任何内容(例如插入 space 或注释)然后您再次 运行 它,它将被编译并再次 运行 。您会通过增加的响应时间注意到它。使用当前版本 (Go 1.6),您每次都会看到相同的输出。
运行 本地(在您的机器上):
当你在本地 运行 时,很可能 GOMAXPROCS
会大于 1
因为它默认为可用的 CPU 内核数(自 Go 1.5 起) .所以如果你有一个goroutine执行死循环也没关系,另一个goroutine会同时执行,就是main()
,当main()
returns,你的程序终止;它不会等待其他非 main
goroutines 完成(参见 Spec: Program execution)。
另请注意,即使您将 GOMAXPROCS
设置为 1
,您的应用程序也很可能会在“短”时间内退出,因为调度程序实施将切换到其他 goroutine,而不仅仅是执行永远无限循环(但是,如上所述,这是不确定的)。当它完成时,它将是 main()
goroutine,因此当 main()
完成并且 returns 时,您的应用程序终止。
在 Go Playground 上使用您的应用:
如前所述,默认情况下 GOMAXPROCS
在 Go Playground 上是 1
。但是允许将其设置为更高的值,例如:
runtime.GOMAXPROCS(2)
没有显式同步,执行仍然是不确定的,但是您会观察到不同的执行顺序和终止,而不会 运行 进入超时:
Hello, playground
Here
Here
Here
...
<Here is printed 996 times, then:>
Finished.
在 Go Playground 上试试这个变体。