登录
首页 >  Golang >  Go问答

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

来源:Golang技术栈

时间:2023-03-22 08:28:22 263浏览 收藏

大家好,今天本人给大家带来文章《Golang http服务器在启动无限循环的goroutine时阻塞》,文中内容主要涉及到golang,如果你对Golang方面的知识点感兴趣,那就请各位朋友继续看下去吧~希望能真正帮到你们,谢谢!

问题内容

正如我从 golang 文档中了解到的那样,如果我将 runtime.GOMAXPROCS(8) 设置为 8 核(intel i7)的 cpu,然后启动一个无限循环的 goroutine,其他 goroutines 不应该被阻塞,因为有足够的线程和 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 

现在我知道为什么这样的 emtpy 循环会阻塞其他 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的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《Golang http服务器在启动无限循环的goroutine时阻塞》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:Golang技术栈 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表