我如何处理Goroutines的恐慌？

Question

我对golang还很陌生。所以，请把剑给我（如果可能的话）。

我试图通过学习这里的教程从web上获取数据

在问之前，我看了很多参考资料，比如：

1. 博客延迟，恐慌和恢复
2. 在Goroutines中处理恐慌
3. how-show-i-write-goroutine

还有几个，但我想不通。

以下是你不想去游乐场的代码（原因尚不为人所知）：

// MakeRequest : Makes requests concurrently
func MakeRequest(url string, ch chan<- string, wg *sync.WaitGroup) {
    start := time.Now()
    resp, err := http.Get(url)
    defer func() {
        resp.Body.Close()
        wg.Done()
            if r := recover(); r != nil {
                fmt.Println("Recovered in f", r)
            }
    }()
    if err != nil {
        fmt.Println(err)
        panic(err)
    }
    secs := time.Since(start).Seconds()
    body, _ := ioutil.ReadAll(resp.Body)

    ch <- fmt.Sprintf("%.2f elapsed with response length: %d %s", secs, len(body), url)
}

func main() {
    var wg sync.WaitGroup
    output := []string{
        "https://www.facebook.com",
        "",
    }
    start := time.Now()
    ch := make(chan string)
    for _, url := range output {
        wg.Add(1)
        go MakeRequest(url, ch, &wg)
    }

    for range output {
        fmt.Println(<-ch)
    }
    fmt.Printf("%.2fs elapsed\n", time.Since(start).Seconds())
}

我将代码修改为（假设）处理goroutine中的错误，如下所示（go-playground）：

func MakeRequest(url string, ch chan<- string, wg *sync.WaitGroup) {
    start := time.Now()
    resp, err := http.Get(url)

    if err == nil {
        secs := time.Since(start).Seconds()
        body, _ := ioutil.ReadAll(resp.Body)

        ch <- fmt.Sprintf("%.2f elapsed with response length: %d %s", secs, len(body), url)
        // fmt.Println(err)
        // panic(err)
    }
    defer wg.Done()
}

回答后，我将代码更改为此，它成功地移除了chan死锁，但是现在我需要在main中处理此问题：

func MakeRequest(url string, ch chan<- string, wg *sync.WaitGroup) {
    defer wg.Done()
    start := time.Now()
    resp, err := http.Get(url)

    if err == nil {
        secs := time.Since(start).Seconds()
        body, _ := ioutil.ReadAll(resp.Body)

        ch <- fmt.Sprintf("%.2f elapsed with response length: %d %s", secs, len(body), url)
        // fmt.Println(err)
        // panic(err)
    }
    // defer resp.Body.Close()
    ch <- fmt.Sprintf("")
}

但现在我陷入了僵局。

感谢和问候。
Temporarya
（阿戈朗·努比）

Answer 1

您正确地使用了恢复。您有两个问题：

>

您错误地使用了panic。只有在出现编程错误时才应该惊慌。避免使用恐慌，除非你相信删除程序是对所发生的事情的合理反应。在这种情况下，我只会返回错误，而不是panic。

你在恐慌中惊慌失措。正在发生的情况是，您首先在panic(err)执行panish操作。然后在defer函数中，在resp.body.close()处进行panising。当http.get返回错误时，它返回一个nil响应。这意味着resp.body.close()作用于一个nil值。

func MakeRequest(url string, ch chan<- string, wg *sync.WaitGroup) {
    defer wg.Done()
    start := time.Now()
    resp, err := http.Get(url)
    if err != nil {
        //handle error without panicing
    }
    // there was no error, so resp.Body is guaranteed to exist.
    defer resp.Body.Close()
    ...

操场

func main() {
    var wg sync.WaitGroup
    output := []string{
        "https://www.facebook.com",
        "",
    }
    start := time.Now()
    ch := make(chan string)
    for _, url := range output {
        wg.Add(1)
        go MakeRequest(url, ch, &wg)
    }

    go func() {
        wg.Wait()
        close(ch)
    }()

    for val := range ch {
        fmt.Println(val)
    }
    fmt.Printf("%.2fs elapsed\n", time.Since(start).Seconds())
}