【发布时间】：2014-12-24 20:08:19
【问题描述】：
正如我从 golang 文档中了解到的，如果我将 runtime.GOMAXPROCS(8) 设置为 8 核的 cpu (intel i7)，然后启动一个无限循环的 goroutine，其他 gorutines 不应该被阻塞，因为有足够多的线程和goprocs。但是当使用 net/http 包时情况并非如此，一个无限循环的 goroutine 会在几次调用后阻塞 http 服务器。 谁能帮忙解释一下原因？
- 如果我注释“无限循环”这行，在服务器之后启动客户端，客户端将输出1000个星号；但是如果我启用 goroutine，客户端会在打印几个星号后阻塞
- 我试过在goroutine中添加runtime.LockOSThread()，好像不行
- 我的环境：osx 10.10，go 版本 go1.3.1 darwin/amd64
服务器代码：
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()
}
}
}
现在我知道为什么这样的 emtpy 循环会阻塞其他 goroutine，但为什么 runtime.LockOSThread() 也没有帮助？
func infiniteloop() {
// add LockOSThread will not help
runtime.LockOSThread()
for {
}
}
正如http://golang.org/pkg/runtime/#LockOSThread 提到的，空循环应该在独立线程中执行，其他 goroutine 不应受到忙循环的影响。我的理解有什么问题？
【问题讨论】：
-
“无限”循环不是问题。这是一个繁忙的循环，除了消耗 CPU 之外什么都不做，这是个问题。
-
@Grzegorz Żur 您确定客户端可以打印所有 1000 个星号吗？我已经交叉编译了源文件并在 linux/amd64 平台上运行它们。客户端在停止前打印了大约 150 个星号
-
@user922965 我的错误，我在注释掉关键行的情况下运行它。我重做测试，它阻塞了。
-
我得到了同样的停止，这是出乎意料的，一定是调度程序的限制吗？也许提交错误报告:)
-
我用 go1.4beta1 linux/amd64 版本运行代码，它没有打印一个字符。 :-( 我认为这是golang-nuts 的一个好问题。