并发 go 函数中使用锁来保护共享数据，以避免数据竞态并确保数据一致性。首先，创建 mutex 实例（基本锁）并使用 lock() 和 unlock() 方法获取和释放锁来保护需要保护的代码段。实战案例演示了如何使用 mutex 来保护并发计数器，多个协程同时对它进行增量操作。

如何使用锁来保护并发 Go 函数

在并发 Go 程序中，多个协程同时访问共享数据时，有必要使用锁来确保数据一致性和避免数据竞态。本文将探讨如何在 Go 函数中使用锁，并提供一个实战案例。

使用 Mutex

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

Mutex（互斥锁）是一个基本锁，它保证同一时刻只有一个协程可以访问受保护的资源。要使用 Mutex，首先需要创建一个 Mutex 实例：

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

var mu sync.Mutex

然后，在需要保护的代码段中，使用 Lock() 和 Unlock() 方法来获取和释放锁：

func protect(a int) int {
    mu.Lock()
    defer mu.Unlock()

    // 受保护的代码
    return a + 1
}

实战案例：并发计数器

考虑一个并发计数器，多个协程同时对它进行增量操作。如果不使用锁，可能会出现数据竞态，导致计数器值不准确。

可以使用 Mutex 来保护并发计数器：

package main

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

// 计数器结构
type Counter struct {
    mu sync.Mutex
    Count int
}

// 对计数器进行增量操作
func (c *Counter) Increment() {
    c.mu.Lock()
    defer c.mu.Unlock()

    c.Count++
}

func main() {
    // 创建计数器
    c := Counter{}

    // 创建协程并进行并发增量操作
    for i := 0; i < 10; i++ {
        go c.Increment()
    }

    // 等待所有协程完成
    runtime.Gosched()

    // 打印最终计数器值
    fmt.Println(c.Count)
}

结论

使用锁可以有效地保护并发 Go 函数中的共享数据，防止数据竞态和确保数据一致性。本文中的实战案例展示了如何使用 Mutex 来保护并发计数器。