Golang:goroutine无限循环

xge*_*ged 3 infinite-loop go

fmt.Print()从下面的代码中删除一行时,代码无限运行.为什么?

package main

import "fmt"
import "time"
import "sync/atomic"

func main() {
        var ops uint64 = 0 
        for i := 0; i < 50; i++ {
                go func() {
                        for {
                                atomic.AddUint64(&ops, 1)
                                fmt.Print()
                        }
                }()
        }
        time.Sleep(time.Second)
        opsFinal := atomic.LoadUint64(&ops)
        fmt.Println("ops:", opsFinal)
}
Run Code Online (Sandbox Code Playgroud)

Von*_*onC 8

围棋by example文章包括:

   // Allow other goroutines to proceed.
   runtime.Gosched()
Run Code Online (Sandbox Code Playgroud)

fmt.Print()扮演了类似的角色,并允许main()有机会继续进行.

export GOMAXPROCS=2即使在无限循环的情况下,A 可能有助于程序完成,如" golang:goroute with select不会停止,除非我添加了fmt.Print() ".

fmt.Print() 显式地将控制传递给某些系统调用


是的,go1.2 +在调度程序中有优先权

在以前的版本中,永远循环的goroutine可能会在同一个线程上饿死其他goroutine,当GOMAXPROCS只提供一个用户线程时这是一个严重的问题.

在Go 1.2中,部分解决了这个问题:在进入函数时偶尔会调用调度程序.这意味着任何包含(非内联)函数调用的循环都可以被抢占,允许其他goroutine在同一个线程上运行.

请注意重点(我提出):在您的示例中,有可能atomic.AddUint64(&ops, 1)内联for循环.那里没有先发制人.


2017年更新:Go 1.10将被淘汰GOMAXPROCS.