在Go语言中,互斥锁(Mutex)是一种用于保护共享资源的同步原语。它可以帮助你在多个goroutine之间实现互斥访问。要正确使用Go语言的互斥锁,请遵循以下步骤:
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++
}