处理 goroutine 中的恐慌的方法

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《处理 goroutine 中的恐慌的方法》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

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

我试图通过学习此处的教程来从网络获取数据

现在，教程一切顺利，但我想检查边缘情况和错误处理（只是为了彻底了解我对语言的新学习，不想成为知识不成熟的人） .

这是我的演示代码。

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

1. 转到博客延迟、恐慌和恢复
2. 处理 goroutine 中的恐慌
3. 我应该如何编写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 中的错误（此处为演示）：

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

更新 2：

在回答之后，我将代码更改为这个，它成功地消除了 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("")
}

没有更优雅的方式来处理这个问题吗？

但现在我陷入了僵局。

感谢和问候。

临时性

（一个 golang 菜鸟）

解决方案

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

1. 您错误地使用了恐慌。仅当出现编程错误时才应该惊慌。避免使用恐慌，除非您认为关闭该程序是对所发生事件的合理反应。在这种情况下，我只会返回错误，而不是恐慌。

2. 你在恐慌期间感到恐慌。发生的情况是，您首先对 panic(err) 感到恐慌。然后在您的 defer 函数中，您对 resp.body.close() 感到恐慌。当 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()
    ...

对更新的响应： 如果http.get() 返回错误，则您永远不会在通道上发送。在某些时候，除了主 goroutine 之外的所有 goroutine 都停止运行，并且主 goroutine 正在等待 <-ch。由于该通道接收永远不会完成，并且 go 运行时没有其他内容可以安排，因此它会出现恐慌（无法恢复）。

对评论的回复：为了确保频道不会挂起，您需要某种协调来了解消息何时停止发送。如何实现取决于您的实际程序，并且示例不一定能推断出现实。对于此示例，我将在 waitgroup 完成后简单地关闭通道。

Playground

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

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。