dougou6213 2019-06-26 17:13
浏览 172
已采纳

(goroutine泄漏)http.TimeoutHandler不会杀死相应的ServeHTTP goroutine

Timeout handler moves ServeHTTP execution on a new goroutine, but not able to kill that goroutine after the timer ends. On every request, it creates two goroutines, but ServeHTTP goroutines never kill with context.

Not able to find a way to kill goroutines.

Edit For-loop with time.Sleep function, represents huge computation which goes beyond our timer. Can replace it with any other function.

package main

import (
    "fmt"
    "io"
    "net/http"
    "runtime"
    "time"
)

type api struct{}

func (a api) ServeHTTP(w http.ResponseWriter, req *http.Request) {
    // For-loop block represents huge computation and usually takes more time
    // Can replace with any code
    i := 0
    for {
        if i == 500 {
            break
        }
        fmt.Printf("#goroutines: %d
", runtime.NumGoroutine())
        time.Sleep(1 * time.Second)
        i++
    }
    _, _ = io.WriteString(w, "Hello World!")
}

func main() {
    var a api
    s := http.NewServeMux()
    s.Handle("/", a)
    h := http.TimeoutHandler(s, 1*time.Second, `Timeout`)

    fmt.Printf("#goroutines: %d
", runtime.NumGoroutine())

    _ = http.ListenAndServe(":8080", h)
}

ServeHTTP goroutine should kill along with request context, normally which does not happen.

  • 写回答

2条回答 默认 最新

  • douniuta4783 2019-07-25 16:15
    关注

    I found, if you do not have any way to reach to your channel then there is no way to kill or stop goroutine when it is running.

    In the large computational task, you have to watch the channel on a specific interval or after specific task completion.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?