常见的 Go 例程的重新启动方式

一分耕耘，一分收获！既然打开了这篇文章《常见的 Go 例程的重新启动方式》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我有两个 go 例程执行两个长时间运行的任务。在某些情况下，这些例程可能会出错。我想看看是否有办法在出错后重新启动例程。如果例行程序被取消，我还必须避免重新启动。

我现在添加了以下代码。请建议这是否是一种惯用的方法。

func f1(ctx context.Context) error {
    fmt.Println("[f1] start")
    select {
    case <-ctx.Done():
        fmt.Println("[f1] graceful exit")
        return nil
    }
}

func f2(ctx context.Context) error {
    fmt.Println("[f2] start")
    select {
    case <-time.After(1 * time.Second):
        // simulating an error condition
        fmt.Println("[f2] errored exit")
        return fmt.Errorf("error")
    case <-ctx.Done():
        fmt.Println("[f2] graceful exit")
        return nil
    }
}

func manage(ctx context.Context, f func(ctx context.Context) error) {
    for {
        err := f(ctx)
        if err == nil {
            return
        }
        <-time.After(1 * time.Second)
    }
}

func main() {
    ctx, cancel := context.WithCancel(context.Background())

    go manage(ctx, f1)
    go manage(ctx, f2)

    // delay to see the exeution
    <-time.After(5 * time.Second)
    cancel()
    <-time.After(5 * time.Second)
}

正确答案

没有惯用的方法可以做到这一点。 Go 例程不会随意终止并且需要重新启动。

要么处理 go 例程内部的错误并防止其结束，要么将错误传回例程启动点，在那里处理它，然后在适当的情况下在不同的输入上重新运​​行 go 例程。

今天关于《常见的 Go 例程的重新启动方式》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！