使用 goroutine 的正确方法是什么？

Question

我需要对每个请求应用一些测试，并根据测试结果进行响应。如果其中一项测试失败，我需要立即发送响应，否则我会在所有测试成功完成后等待。我想用并发来做那个测试。现在，我这样做（简化）：func handler_request_checker(w http.ResponseWriter, r *http.Request) {    done := make(chan bool)    quit := make(chan bool)    counter := 0    go TestOne(r,done,quit)    go TestTwo(r,done,quit)    ..............    go TestTen(r,done,quit)    for {        select {            case <- quit:                fmt.Println("got quit signal")                return            case <- done:                counter++                if counter == 10 {                    fmt.Println("All checks passed succesfully")                    return                }        }    }func main() {    http.HandleFunc("/", handler_request_checker)    http.ListenAndServe()}goroutine 之一的示例：func TestOne(r *http.Request, done,quit chan bool) {    ip,_,ok := net.SplitHostPort(r.RemoteAddr)    if ok == nil {        for _,item := range BAD_IP_LIST {            if strings.Contains(ip,item) {                quit <- true                return            }        }        done <- true        return    } else {        quit <- true        return    }}问题是 goroutines 在我没有退出信号后不会释放内存。我想这是因为在完成的香奈儿里有一些东西。我是 GO 新手，所以也许我用错了方法？例如，当我开始 load check 时http_load -parallel 10 -seconds 10，该 goroutine 很容易吃掉 100+ MB 的 RAM，并且不会将其返还给系统。在下一次检查时，它会多吃 100+ MB，依此类推。如果我在没有go（逐步）的情况下进行测试，则程序在进行任何负载检查时不会超过 10-15mb

Answer 1

你的猜测是对的。您正在使用同步通道，这意味着发送方和接收方都必须可用才能传输值。

一旦您的handler_request_checker函数收到退出信号，它就会停止检索done和quit通道的任何值。此外TestOne，TestTwo当他们尝试发送结果时，goroutines 将被阻止。更糟糕的是，它们将永远留在内存中，因为它们仍在运行，因为它们尚未传输结果。

解决该问题的一个方法是使用缓冲（异步）通道done和quit。例如：

done := make(chan bool, 10)
quit := make(chan bool, 10)

如果您在 10 个测试中使用大小为 10 的缓冲区，那么所有 goroutine 都能够发送它们的结果，即使不再有可用的读取器。所有 goroutine 将干净地退出，并且一旦所有 goroutine 退出，通道（可能包含一些未读结果）将被垃圾收集。