正如我从golang文档中了解到的,如果我使用8个内核的cpu(intel i7)设置runtime.GOMAXPROCS(8),然后启动无限循环goroutine,则不应阻塞其他gorutine,因为有足够的线程和goprocs。但是,当使用net / http包时,情况并非如此,无限循环goroutine会在几次调用后阻塞http服务器。谁能帮助解释原因?
服务器代码:
package main import ( "fmt" "log" "net/http" "runtime" ) func myHandler(w http.ResponseWriter, req *http.Request) { w.Write([]byte("hello")) } func infiniteloop() { for { } } func main() { // set max procs for multi-thread executing runtime.GOMAXPROCS(runtime.NumCPU()) // print GOMAXPROCS=8 on my computer fmt.Println("GOMAXPROCS=", runtime.GOMAXPROCS(-1)) http.Handle("/", http.HandlerFunc(myHandler)) // uncomment below line cause server block after some requests // go infiniteloop() if err := http.ListenAndServe(":8280", nil); err != nil { log.Fatal(err) } }
客户代码:
package main import ( "fmt" "net/http" ) func getOnce() { if resp, err := http.Get("http://localhost:8280"); err != nil { fmt.Println(err) return } else { defer func() { if err := resp.Body.Close(); err != nil { fmt.Println(err) } }() if resp.StatusCode != 200 { fmt.Println("error codde:", resp.StatusCode) return } else { fmt.Print("*") } } } func main() { for i := 1; i < 1000; i++ { getOnce() if i%50 == 0 { fmt.Println() } } }
现在我知道为什么这样的空循环会阻塞其他goroutine,但是为什么runtime.LockOSThread()也没有帮助?
runtime.LockOSThread()
func infiniteloop() { // add LockOSThread will not help runtime.LockOSThread() for { } }
如http://golang.org/pkg/runtime/#LockOSThread所述,空循环应在独立线程中执行,而其他goroutine不应受到繁忙循环的影响。我的理解有什么问题?
目前,Go运行时的调度程序尚未完全抢占。Go 1.2的改进之处在于,有时会在函数调用中调用调度程序,但是示例中的无限循环没有函数调用,因此这无济于事。
有了无限循环处理程序的实际主体,您可能会看到更好的行为。另外,runtime.Gosched在这种情况下,手动调用可能会有所帮助。
runtime.Gosched