如何在 Golang 中使用 Mutex 锁保护资源_Golang 并发安全控制基础教程

Mutex是互斥锁,用于防止多个goroutine并发访问共享资源导致数据竞争。通过Lock()加锁、Unlock()释放,确保同一时间仅一个协程访问临界区,如用sync.Mutex保护计数器变量可避免递增操作时的数据不一致问题。

在 Golang 中,多个 goroutine 同时访问共享资源时容易引发数据竞争问题。为了避免这种情况,可以使用 sync.Mutex 来实现对临界区的互斥访问,确保同一时间只有一个 goroutine 能操作共享资源。

什么是 Mutex?

Mutex 是 "Mutual Exclusion" 的缩写,中文叫“互斥锁”。它是一种同步原语,用于控制多个协程对共享资源的访问。在 Go 中,sync.Mutex 提供了两个核心方法:

  • Lock():获取锁,如果已被其他协程持有,则阻塞等待
  • Unlock():释放锁,必须由加锁的协程调用,否则会引发 panic

正确使用这两个方法,就能有效防止并发读写导致的数据不一致。

如何用 Mutex 保护变量

下面是一个典型的例子:多个 goroutine 同时对一个计数器进行递增操作。如果不加锁,结果可能不准确。

package main

import (
    "fmt"
    "sync"
    "time"
)

var (
    counter = 0
    mutex   sync.Mutex
)

func increment(wg *sync.WaitGroup) {
    defer wg.Done()
    for i := 0; i < 1000; i++ {
        mutex.Lock()
        counter++
        mutex.Unlock()
    }
}

func main() {
    var wg sync.WaitGroup

    for i := 0; i < 5; i++ {
        wg.Add(1)
        go increment(&wg)
    }

    wg.Wait()
    fmt.Println("最终计数:", counter) // 正确输出应为 5000
}

在这个例子中,每次修改 counter 前都先调用 mutex.Lock(),修改完成后立即调用 Unlock()。这保证了任意时刻只有一个 goroutine 能修改该变量。

使用 defer 自动解锁

为了防止忘记释放锁(尤其是在函数提前返回或发生错误时),推荐使用 defer mutex.Unlock() 来确保锁一定会被释放。

mutex.Lock()
defer mutex.Unlock()

// 操作共享资源
counter++

这种方式更安全,即使后续代码出现 panic 或 return,Unlock 也会被执行。

常见使用场景和注意事项

除了基本变量,Mutex 还常用于保护结构体字段、map、slice 等共享数据结构。

  • 不要重复加锁:同一个 goroutine 多次调用 Lock() 会导致死锁
  • 配对调用:每个 Lock() 都要有对应的 Unlock()
  • 作用范围要合理:锁的粒度不宜过大,避免影响性能;也不宜过小,导致保护不足
  • 避免在持有锁时做耗时操作(如网络请求、长时间计算)

基本上就这些。掌握 Mutex 的使用是理解 Go 并发安全的基础。只要记住:共享资源 + 并发写 = 必须加锁。写代码时多留意数据竞争的可能性,合理使用 Lock 和 defer Unlock,就能写出安全高效的并发程序。