Golang协程调度
发布时间:2020-12-16 18:13:44 所属栏目:大数据 来源:网络整理
导读:有时候可能会出现这种情况,一个无耻的goroutine阻止其他goroutine运行。当你有一个不让调度器运行的 for循环时,这就会发生。 package mainimport "fmt"func main() { done := false go func(){ done = true }() for !done { } fmt.Println("done!")} for循
有时候可能会出现这种情况,一个无耻的goroutine阻止其他goroutine运行。当你有一个不让调度器运行的 for循环时,这就会发生。
package main import "fmt" func main() { done := false go func(){ done = true }() for !done { } fmt.Println("done!") }for循环并不需要是空的。只要它包含了不会触发调度执行的代码,就会发生这种问题。 调度器会在GC、“go”声明、阻塞channel操作、阻塞系统调用和lock操作后运行。它也会在非内联函数调用后执行。即如下情况会触发goroutine调度:
具体的实现都在src/runtime/proc.c里,而要完成主动抢占,Go是采用在stack上做标记(g->stackguard0=StackPreempt),每次函数调用的时候会检查是否需要抢占,于是要想真的抢占goroutine CPU,只能等它调用任意一个非内联的函数。 package main import "fmt" func main() { done := false go func(){ done = true }() for !done { fmt.Println("not done!") //not inlined } fmt.Println("done!") }要想知道你在 for循环中调用的函数是否是内联的,你可以在“go build”或“go run”时传入“-m” gc标志(如, go build -gcflags -m)。 另一个选择是显式的唤起调度器。你可以使用“runtime”包中的 Goshed()函数。
package main import ( "fmt" "runtime" ) func main() { done := false go func(){ done = true }() for !done { runtime.Gosched() } fmt.Println("done!") } (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |