在Go语言中,互斥锁(Mutex)是一种用于保护共享资源的同步原语。它可以帮助你在多个goroutine之间实现互斥访问。要正确使用Go语言的互斥锁,请遵循以下步骤:
- 导入"sync"包:
import "sync"
- 创建一个互斥锁实例:
var mu sync.Mutex
- 在访问共享资源之前,使用
mu.Lock()
加锁:
mu.Lock() // 访问共享资源的代码
- 在访问完共享资源后,使用
mu.Unlock()
解锁:
// 访问共享资源的代码 mu.Unlock()
这是一个简单的示例,展示了如何使用互斥锁保护共享资源:
package main import ( "fmt" "sync" ) var ( counter = 0 mu sync.Mutex ) func increment() { mu.Lock() counter++ mu.Unlock() } func main() { var wg sync.WaitGroup for i := 0; i < 1000; i++ { wg.Add(1) go func() { defer wg.Done() increment() }() } wg.Wait() fmt.Println("Counter:", counter) }
在这个示例中,我们有一个名为counter
的共享资源和一个名为mu
的互斥锁。我们创建了一个名为increment
的函数,该函数在访问counter
之前加锁,并在访问完成后解锁。在main
函数中,我们启动了1000个goroutine并发地调用increment
函数,并使用sync.WaitGroup
等待所有goroutine完成。最后,我们打印出counter
的值,它应该是1000。
注意:在使用互斥锁时,请确保在访问共享资源之前加锁,并在访问完成后解锁。如果忘记解锁,可能会导致死锁。为了避免这种情况,可以使用defer
语句在函数返回时自动解锁:
func increment() { mu.Lock() defer mu.Unlock() counter++ }