Goroutine 不运行

Question

我正在尝试使用 goroutine 将项目写入数据库。然而，由于某种原因，goroutine 似乎没有做任何事情。

我有以下功能：

func addEvent(w http.ResponseWriter, r *http.Request) {
    body, err := ioutil.ReadAll(r.Body)
    fmt.Println(string(body[:]))

    if err != nil {
        panic(err)
    }

    eventCh := make(chan []byte)
    eventCh <- body
    go models.WriteEventToDb(eventCh)

}

和

func WriteEventToDb(eventCh chan []byte) {
    fmt.Println("event")
    event := <-eventCh
    newEvent := createNewEvent(event)
    err := db.Insert(&newEvent)

    if err != nil {
        panic(err)
    }

}

知道为什么 WriteEventToDb 不运行吗？

Answer 1

你的函数在启动 goroutine 之前就阻塞了：

eventCh := make(chan []byte)
eventCh <- body

这会创建一个新通道，在将其传递给任何其他例程之前，它会尝试向该通道发送消息。由于通道是无缓冲的并且没有任何内容从它读取，因此发送会无限期地阻塞。