如何处理 Golang 并发函数中的错误？-Golang-PHP中文网

如何处理 Golang 并发函数中的错误？

PHPz

发布： 2024-09-16 18:27:01

原创

806人浏览过

在 go 并发函数中处理错误的方法有：使用 sync.errorgroup：它收集第一个发生的错误并返回。使用 channels：在 goroutine 之间通信错误，允许发送和接收错误消息。使用 recover：捕捉并发函数中的 panic 并返回引发 panic 的值。

如何处理 Golang 并发函数中的错误？

如何处理 Go 并发函数中的错误

在并发程序中，处理错误至关重要。Go 提供了多种机制来处理并发函数中发生的错误。

使用 ErrorGroup

立即学习“go语言免费学习笔记（深入）”；

sync.ErrorGroup 是一个用于管理多个并发操作并收集其中任何一个产生的第一个错误的结构。函数 Add(f func()) error 向组中添加一个操作。每次调用该函数时，错误会被存储在组中。调用 Wait() 时，它将返回遇到的第一个错误（如果有）。

动态WEB网站中的PHP和MySQL：直观的QuickPro指南第2版

动态WEB网站中的PHP和MySQL详细反映实际程序的需求，仔细地探讨外部数据的验证(例如信用卡卡号的格式)、用户登录以及如何使用模板建立网页的标准外观。动态WEB网站中的PHP和MySQL的内容不仅仅是这些。书中还提到如何串联JavaScript与PHP让用户操作时更快、更方便。还有正确处理用户输入错误的方法，让网站看起来更专业。另外还引入大量来自PEAR外挂函数库的强大功能，对常用的、强大的包

508

查看详情

import (
    "context"
    "fmt"
    "sync"
    "sync/atomic"
)

func main() {
    var eg sync.ErrGroup
    var count int64
    for i := 0; i < 10; i++ {
        eg.Add(func() error {
            atomic.AddInt64(&count, 1)
            fmt.Printf("Count: %d\n", count)
            if count%2 == 0 {
                return fmt.Errorf("even count: %d", count)
            }
            return nil
        })
    }

    if err := eg.Wait(); err != nil {
        fmt.Println(err)
    }
}

登录后复制

使用 Channels

Channels 可用于在并发函数之间通信，包括错误。使用 channel，您可以将错误消息发送给一个指定 channel，然后从另一个 goroutine 中接收它们。

import (
    "context"
    "fmt"
    "sync"
)

func main() {
    ctx := context.Background()
    errCh := make(chan error)
    wg := sync.WaitGroup{}

    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()
            if i%2 == 0 {
                errCh <- fmt.Errorf("even number: %d", i)
                return
            }
            errCh <- nil
        }(i)
    }

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

    for err := range errCh {
        if err != nil {
            fmt.Println(err)
        }
    }
}

登录后复制

使用 recover

使用 recover 语句可以 catch 发生在并发函数中的 panic。recover() 返回引发 panic 的值。

import (
    "context"
    "fmt"
    "sync"
)

func main() {
    ctx := context.Background()
    errCh := make(chan error)
    wg := sync.WaitGroup{}

    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()
            if i%2 == 0 {
                panic(fmt.Errorf("even number: %d", i))
            }
            errCh <- nil
        }(i)
    }

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

    for err := range errCh {
        if err != nil {
            fmt.Println(err)
        }
    }

    // 在主 goroutine 中 recover 任何未处理的 panic
    defer func() {
        if r := recover(); r != nil {
            fmt.Println("Recovered:", r)
        }
    }()
}

登录后复制

以上就是如何处理 Golang 并发函数中的错误？的详细内容，更多请关注php中文网其它相关文章！