go 函数并发编程可通过同步原语（如互斥锁）协调共享资源访问，减少数据竞争和死锁风险。利用错误处理和返回值，可检测和报告并发操作中的错误。panic 和 recovery 机制可以捕获和处理异常，防止程序崩溃。通过使用互斥锁来保护共享数据的并发访问，可以避免数据重复或丢失等并发错误。

Go 函数并发编程如何检测和处理并发错误？

Go 语言的并发编程功能强大，但也存在并发错误的风险。本文将介绍如何检测和处理并发错误，确保程序的稳定性。

同步原语

Go 提供了一些同步原语来协调并发访问共享资源，如互斥锁、读写锁和条件变量。这些原语可以帮助防止数据竞争和死锁等并发错误。

错误处理

Go 语言中，函数可以通过 error 返回值返回错误。在并发上下文中，错误处理可以用来检测和报告并发操作期间发生的错误。

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

示例：

func safeIncrement(n *int, wg *sync.WaitGroup) error {
    if n == nil {
        return errors.New("nil pointer exception")
    }
    wg.Done()
    *n++
    return nil
}

func main() {
    var n int
    var wg sync.WaitGroup
    for i := 0; i < 100; i++ {
        wg.Add(1)
        go func() {
            if err := safeIncrement(&n, &wg); err != nil {
                log.Fatal(err)
            }
        }()
    }
    wg.Wait()
}

上述示例中，safeIncrement 函数通过 error 返回值检测并发写入共享变量 n 时的 nil 指针异常。如果检测到错误，会通过 log.Fatal 函数记录并停止程序。

Panic 和 Recovery

Panic 是一个非致命异常，它会停止程序的正常执行。Recovery 可以捕获和处理 panic，从而防止程序崩溃。

示例：

func recoverExample() {
    defer func() {
        if err := recover(); err != nil {
            log.Println(err)
        }
    }()
    
    var n *int
    fmt.Println(*n) // 这里会触发 panic
}

func main() {
    recoverExample()
}

上述示例中，defer 会创建一个匿名函数，当函数返回或 panic 时，匿名函数会被调用。匿名函数使用 recover 捕获 panic，并将其记录到日志中。这有助于检测和处理并发 panic。

实战案例

考虑以下并发应用程序：

package main

import (
    "fmt"
    "runtime"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    var data []int

    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()
            for j := 0; j < 5; j++ {
                data = append(data, i*j)
            }
        }(i)
    }
    wg.Wait()

    fmt.Println(data) // 可能包含重复元素
}

该应用程序尝试并发写入共享切片 data。由于切片被竞争写入，可能会导致数据重复或丢失。

修正后的版本：

package main

import (
    "fmt"
    "runtime"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    var data []int

    mu := &sync.Mutex{}

    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()
            for j := 0; j < 5; j++ {
                mu.Lock()
                data = append(data, i*j)
                mu.Unlock()
            }
        }(i)
    }
    wg.Wait()

    fmt.Println(data) // 正确的数据，无重复
}

在修改后的版本中，我们使用互斥锁 mu 来保护 data 的并发写入。这确保了在任何给定时间，只有一个 goroutine 可以写入数据。