go 中的锁机制支持并发编程下的数据访问安全,提供了多种锁类型以满足不同场景:sync.mutex:互斥锁,一次仅允许一个协程持有。sync.rwmutex:读写锁,允许多个协程同时读取数据,但仅允许一个协程写入。sync.once:一次性锁,确保一个操作仅执行一次。在实战中,可以通过使用锁来保护共享数据的并发访问,如在 counter 类型中使用互斥锁保护对 count 的增量操作,确保每次仅有一个协程执行此操作,避免竞争情况。
Go 函数中的锁机制
介绍
并发编程中,多个协程同时访问共享数据时,需要使用锁机制来保证数据的一致性和安全性。Go 中提供了丰富的锁类型,可以满足不同的并发场景。
锁类型
立即学习“go语言免费学习笔记(深入)”;
点击下载“修复打印机驱动工具”;
Go 中常用的锁类型有:
- sync.Mutex: 互斥锁,一次只能有一个协程持有该锁。
- sync.RWMutex: 读写锁,可以同时有多个协程读取数据,但只有一个协程可以写入数据。
- sync.Once: 一次性锁,保证一个操作只执行一次。
实战案例:
假设有一个 Counter 类型,其包含一个 Count 字段,用于记录计数值。多个协程需要并发地对 Count 进行增量操作,同时保证其不会出现竞争情况。
package main
import (
"fmt"
"sync"
"time"
)
type Counter struct {
mu sync.Mutex
Count int
}
func main() {
var counter Counter
// 创建 10 个协程并发地对 Count 进行增量操作
for i := 0; i < 10; i++ {
go func() {
for j := 0; j < 1000; j++ {
counter.Increment()
}
}()
}
// 等待协程执行完毕
time.Sleep(time.Second)
// 打印最终计数值
fmt.Println("Final Count:", counter.Count)
}
// 使用互斥锁实现安全的增量操作
func (c *Counter) Increment() {
c.mu.Lock()
c.Count++
c.mu.Unlock()
}
在这个示例中,我们使用互斥锁 sync.Mutex 保护对 Count 的增量操作,确保每次只能有一个协程持有该锁,从而防止竞争情况。