golang互斥锁正确使用方法

在Go语言中，互斥锁（Mutex）是一种常见的同步机制，用于保护共享资源的访问。使用互斥锁可以确保在任意时刻只有一个goroutine能够访问被保护的代码段，从而避免并发访问导致的数据竞争问题。本文将介绍如何正确使用互斥锁。

定义和初始化互斥锁

在使用互斥锁之前，首先需要创建一个互斥锁对象，并进行初始化。在Go语言中，可以使用sync包提供的Mutex类型来定义互斥锁。下面是创建和初始化互斥锁的示例代码：

import "sync"

var mutex sync.Mutex

func main() {
    // 初始化互斥锁
    mutex = sync.Mutex{}
}

加锁和解锁

一旦互斥锁被初始化后，就可以通过调用Lock方法将其锁定（也称为加锁）。加锁后的代码段只能被当前goroutine访问，其他goroutine将被阻塞。当当前goroutine完成对共享资源的访问后，需要调用Unlock方法将互斥锁解锁，以允许其他goroutine访问这个代码段。下面是示例代码：

func main() {
    // 加锁
    mutex.Lock()
    defer mutex.Unlock() // 使用defer语句确保解锁操作一定会执行

    // 访问共享资源的代码
    // ...
}

使用互斥锁保护共享资源

互斥锁最常见的用法是用于保护共享资源的访问。在多个goroutine同时访问同一个共享资源时，必须确保每个goroutine在访问之前先加锁，访问之后再解锁。这样可以避免多个goroutine之间相互干扰，确保数据的正确性。下面是一个使用互斥锁保护共享资源的示例：

import "sync"

var counter int
var mutex sync.Mutex

func main() {
    // 启动多个并发的goroutine
    for i := 0; i < 10; i++ {
        go increment()
    }

    // 等待所有goroutine执行完毕
    time.Sleep(time.Second)

    fmt.Printf("Counter: %d\n", counter)
}

func increment() {
    // 加锁
    mutex.Lock()
    defer mutex.Unlock()

    // 修改共享资源
    counter++
}

在上面的示例中，我们定义了一个counter变量作为共享资源，然后通过使用互斥锁保护increment函数对counter进行递增操作。在main函数中，启动了多个并发的goroutine来并发地调用increment函数，每个goroutine都会对counter进行递增操作。最后，等待所有goroutine执行完毕后打印counter的值。由于使用了互斥锁的保护，我们可以确保counter的值被正确地累加，避免了并发访问导致的竞态条件问题。