将密码恢复传递给上层 Goroutine（ Go 语言）。

Question

我创建了一个示例，在其中并发运行函数，在函数中我触发了恐慌并进行了恢复：

package main

import "fmt"

func main() {
    // "main" recovery
    defer func() {
        if r := recover(); r != nil {
            fmt.Println("main goroutine paniced:", r)
        }
    }()

    // running function concurrently inside which I panic
    chanStr := make(chan string)
    go func() {
        // this "internal" goroutin recovery
        defer func() {
            if r := recover(); r != nil {
                fmt.Println("internal goroutine paniced:", r)
            }
            chanStr <- "hello world"
        }()
        // panicking and wanting recovery not only in "internal" recovery but in "main" recovery as well
        panic("NOT main goroutine")
    }()
    // waiting for chan with "internal" goroutine panicking and recovery
    str := <-chanStr
    fmt.Println(str)

    // panic("main")
}

它会输出：

internal goroutine panicked: NOT main goroutine
hello world

我能否修改代码，将从“internal”恢复密码更改为“main”？换句话说，我想让它在控制台中写下：

internal goroutine paniced: NOT main goroutine
main goroutine paniced: main
hello world

我尝试通过完全删除“内部”恢复功能来实现这一点，但在这种情况下，“主”恢复无法恢复“内部” goroutine 中的 panic。 Playground

更新

我尝试遵循 @Momer 的建议，通过通道发送错误并在主 goroutine 中处理它，而不是尝试将 panic 冒泡：

package main

import (
    "errors"
    "fmt"
)

func main() {
    // "main" recovery
    defer func() {
        if r := recover(); r != nil {
            fmt.Println("main goroutine paniced:", r)
        }
    }()

    // running func concarantly inside which I panic
    chanStr := make(chan string)
    chanErr := make(chan error)
    var err error
    go func() {
        // this "internal" goroutin recovery
        defer func() {
            if r := recover(); r != nil {
                fmt.Println("internal goroutine paniced:", r)
                switch t := r.(type) {
                case string:
                    fmt.Println("err is string")
                    err = errors.New(t)
                case error:
                    fmt.Println("err is error")
                    err = t
                default:
                    fmt.Println("err is unknown")
                    err = errors.New("Unknown error")
                }

                chanErr <- err
                chanStr <- ""
            }
        }()
        // panicing and wanting recovery not only in "internal" recovery but in "main" recovery as well
        panic("NOT main goroutine")
        chanStr <- "hello world"
        chanErr <- nil

    }()
    // waiting for chan with "internal" goroutin panicing and recovery
    str := <-chanStr
    err = <-chanErr
    fmt.Println(str)
    fmt.Println(err)

    // panic("main")
}

它出现了错误

all goroutines are asleep - deadlock

完整输出：

go run /goPath/parentRecoverty2.go
internal goroutine paniced: NOT main goroutine
err is string
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:
main.main()
    /goPath/parentRecoverty2.go:48 +0x1d4

goroutine 5 [chan send]:
main.func·002()
    /goPath/parentRecoverty2.go:37 +0x407
main.func·003()
    /goPath/parentRecoverty2.go:42 +0x130
created by main.main
    /goPath/parentRecoverty2.go:46 +0x190
exit status 2

Update playground

- Maxim Yefremov

---

不要试图将 panic 冒泡到更高的层级，何不通过通道发送一个错误，在主 goroutine 中进行处理？ - Momer

@Momer 我已经尝试过了，但是出现了错误 all goroutines are asleep - deadlock，请查看我上面的更新。 - Maxim Yefremov

你的恢复程序中的第二个写入操作会被阻塞，因为没有人从通道中读取数据。你将多次写入它们，但只读取一次。 - flx

@flx 为什么要写两次？我在第二个恢复块中只在 chanErr 和 chanStr 中写了一次：chanErr <- err chanStr <- ""。 - Maxim Yefremov

Answer 1

我把 golang 中的 panic/recover 理解为 java 或 c++ 中的 try/catch/final 块。

更详细的信息，请访问Handling panics (from Golang spec)。

因此，您可以将 panic 传递给方法的调用者。下面是一个简单的代码示例，希望它能帮助您。

注意：在函数 Foo() 中，我使用 recover() 捕获出现问题的情况，然后重新抛出 panic，以便稍后在外部调用者中捕获它。

package main

import (
    "fmt"
    "time"
)

func Foo() {
    defer func() {
        if x := recover(); x != nil {
            fmt.Printf("Runtime panic: %v \n", x)
            panic("Ah oh ... Panic in defer")
        }
    }()
    panic("Panic in Foo() !")
}

func Game() {
    defer func(){
        fmt.Println("Clean up in Game()")
    }()

    defer func() {
        if x := recover(); x != nil {
            fmt.Println("Catch recover panic !!! In Game()")
        }
    }()
    Foo()

}

func main() {

    defer func() {
        fmt.Println("Program Quit ... ")
    }()

    fmt.Println("-----------Split-------------")
    go Game()
    time.Sleep(1 * time.Millisecond)
    fmt.Println("-----------Split-------------")
}

- Hao Ding

Answer 2

在您更新的问题中，一个线程因从chanStr读取而被阻塞，而另一个线程因写入chanErr而被阻塞。交换写入顺序应该可以解决死锁问题。

defer func() {
    if r := recover(); r != nil {
        fmt.Println("internal goroutine paniced:", r)
        switch t := r.(type) {
        case string:
            fmt.Println("err is string")
            err = errors.New(t)
        case error:
            fmt.Println("err is error")
            err = t
        default:
            fmt.Println("err is unknown")
            err = errors.New("Unknown error")
        }
        chanStr <- ""
        chanErr <- err
    }
}

- flx