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 可以写入数据。
