Golang尝试使方法并发时没有返回

Question

我有一个从数据库返回 Json 的方法，它可以正常工作，但是当我尝试使其并发时，它不会返回任何内容，也不会给出任何错误。例如这是正确工作的方法

func Listing_Expiration(w http.ResponseWriter, r *http.Request)  {

        db,err := sql.Open("DB_Connect")

        if err != nil {
            log.Fatal(err)
            println(err)
        }



        var result string

        errr := db.QueryRow("select json_build_object('Expiration', array_to_json(array_agg(t))) from (select fullname,ad_end from profiles where id=32)t").Scan(&result)


        defer db.Close()
        switch {
        case errr != nil:
            log.Fatal(errr)


        }


        fmt.Fprintf(w,result)

}

上面的方法正常工作，数据返回到浏览器然后我尝试使这个方法异步

 func Listing_Expiration(w http.ResponseWriter, r *http.Request)  {
        go func(){

            db,err := sql.Open("DB_Connect")

            if err != nil {
                log.Fatal(err)
                println(err)
            }



            var result string

            errr := db.QueryRow("select json_build_object('Expiration', array_to_json(array_agg(t))) from (select fullname,ad_end from profiles where id=32)t").Scan(&result)


            defer db.Close()
            switch {
            case errr != nil:
                log.Fatal(errr)


            }


            fmt.Fprintf(w,result)

        }()
    }

上面的异步没有返回任何东西，我唯一改变的是我在方法中添加了 Go func() ，这样它就是异步的，其他的都是一样的。我检查了一下，数据库返回了相同的内容，只是不知道为什么异步没有将结果打印回浏览器。

Answer 1

net/http 服务器在处理程序返回时完成响应。处理程序返回后写入响应的任何内容都将被忽略。

处理函数Listing_Expiration在匿名函数执行fmt.Fprintf(w,result)之前返回。

要解决此问题，请使用sync.WaitGroup：

func Listing_Expiration(w http.ResponseWriter, r *http.Request)  {
  var wg sync.WaitGroup
  wg.Add(1)
  go func(){
    defer wg.Done()
    // same code here as in question
  }()
  wg.Wait()
}

net/http 服务器为每个连接启动一个 goroutine，并在这些 goroutine 中运行处理程序。如果问题中的代码是完整的处理程序，则没有理由启动另一个 goroutine。