Golang http服务器在启动无限循环goroutine时阻塞

  • Z时代
  • 2024-01-10
  • 分类：问答

正如我从golang文档中了解到的，如果我使用8个内核的cpu（intel

i7）设置runtime.GOMAXPROCS（8），然后启动无限循环goroutine，则不应阻塞其他gorutine，因为有足够的线程和goprocs。但是，当使用net

/ http包时，情况并非如此，无限循环goroutine会在几次调用后阻塞http服务器。谁能帮助解释原因？

  1. 如果我注释“无限循环”这一行，则在服务器之后启动客户端，客户端将输出1000个星号；但是，如果我启用了goroutine，客户端将在打印一些星号后阻止

  2. 我试过在goroutine中添加runtime.LockOSThread（），似乎不起作用

  3. 我的环境：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()
        }
    }
}

现在我知道为什么这样的空循环会阻塞其他goroutine，但是为什么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在这种情况下，手动调用可能会有所帮助。

以上是 Golang http服务器在启动无限循环goroutine时阻塞 的全部内容， 来源链接： utcz.com/qa/413491.html

回到顶部