0

我需要对每个请求应用一些测试，并根据测试结果触发响应。如果其中一项测试失败，我需要立即发送响应，否则我将等待所有测试成功完成。我想用并发进行测试。

现在，我这样做（简化）：

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
    }
}

问题是 goroutine 在我退出信号后不会释放内存。我想这是因为完成的香奈儿有一些东西。我是 GO 的新手，所以也许我用错了？

例如，当我开始负载检查时http_load -parallel 10 -seconds 10，该 goroutine 很容易吃掉 100+ MB 的 RAM，并且不会将其还给系统。在下一次检查时，它会多吃 100+ MB，依此类推。

如果我在没有go（逐步）的情况下进行测试，则程序在进行任何负载检查时占用的空间不超过 10-15mb。

4

1 回答 1

2

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

一旦你的函数得到一个退出信号，它就会停止检索和通道handler_request_checker的任何值。此外，, 等 goroutine 在尝试发送结果时将被阻止。更糟糕的是，它们将永远留在内存中，因为它们还没有传输结果，它们仍在运行。donequitTestOneTestTwo

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

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

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

于 2013-08-15T10:34:02.110 回答