当一个goroutine需要访问共享资源时,它可以首先调用Lock()方法来获取锁,只有成功获取锁的goroutine才能进入临界区访问共享资源。其他goroutine在没有获取到锁的情况下,会被阻塞在Lock()方法处,直到锁被释放。
当一个goroutine访问完共享资源后,它可以调用Unlock()方法来释放锁,这样其他处于等待状态的goroutine就有机会获取锁继续执行。
使用同步锁可以有效地避免多个goroutine同时访问共享资源而产生的数据竞争问题。在互斥访问的过程中,同一时刻只能有一个goroutine获得锁,其他goroutine需要等待。
以下是使用同步锁的示例代码:
package main
import (
"fmt"
"sync"
)
var (
count int
wg sync.WaitGroup
mu sync.Mutex
)
func increment() {
defer wg.Done()
for i := 0; i < 1000; i++ {
mu.Lock()
count++
mu.Unlock()
}
}
func main() {
wg.Add(2)
go increment()
go increment()
wg.Wait()
fmt.Println("Final count:", count)
}
上述代码中,我们先创建了一个计数器count和一个等待组wg。然后定义了一个increment函数,该函数会对count进行1000次累加操作。在increment函数中,我们首先调用Lock()方法获取锁,然后对count进行累加操作,最后调用Unlock()方法释放锁。
在main函数中,我们启动了两个goroutine来并发执行increment函数。通过使用同步锁,我们确保了在同一时刻只有一个goroutine能够访问count变量,从而避免了数据竞争问题。
最后,我们等待两个goroutine执行完成,并输出最终的计数结果。