Go语言并发编程之互斥锁Mutex和读写锁RWMutex
作者:Valine 发布时间:2024-04-25 15:00:32
在并发编程中,多个Goroutine
访问同一块内存资源时可能会出现竞态条件,我们需要在临界区中使用适当的同步操作来以避免竞态条件。Go 语言中提供了很多同步工具,本文将介绍互斥锁Mut
ex和读写锁RWMutex
的使用方法。
一、互斥锁Mutex
1、Mutex介绍
Go 语言的同步工具主要由 sync
包提供,互斥锁 (Mutex
) 与读写锁 (RWMutex
) 就是sync 包中的方法。
互斥锁可以用来保护一个临界区,保证同一时刻只有一个 goroutine
处于该临界区内。主要包括锁定(Lock方法)和解锁(Unlock方法)两个操作,首先对进入临界区的goroutine
进行锁定,离开时进行解锁。
使用互斥锁 (Mutex)时要注意以下几点:
不要重复锁定互斥锁,否则会阻塞,也可能会导致死锁(
deadlock
);要对互斥锁进行解锁,这也是为了避免重复锁定;
不要对未锁定或者已解锁的互斥锁解锁;
不要在多个函数之间直接传递互斥锁,
sync.Mutex
类型属于值类型,将它传给一个函数时,会产生一个副本,在函数中对锁的操作不会影响原锁
总之,一个互斥锁只用来保护一个临界区,加锁后记得解锁,对于每一个锁定操作,都要有且只有一个对应的解锁操作,也就是加锁和解锁要成对出现,最保险的做法时使用 defer
语句 解锁。
2、Mutex使用实例
下面的代码模拟取钱和存钱操作:
package main
import (
"flag"
"fmt"
"sync"
)
var (
mutex sync.Mutex
balance int
protecting uint // 是否加锁
sign = make(chan struct{}, 10) //通道,用于等待所有goroutine
)
// 存钱
func deposit(value int) {
defer func() {
sign <- struct{}{}
}()
if protecting == 1 {
mutex.Lock()
defer mutex.Unlock()
}
fmt.Printf("余额: %d\n", balance)
balance += value
fmt.Printf("存 %d 后的余额: %d\n", value, balance)
fmt.Println()
}
// 取钱
func withdraw(value int) {
defer func() {
sign <- struct{}{}
}()
if protecting == 1 {
mutex.Lock()
defer mutex.Unlock()
}
fmt.Printf("余额: %d\n", balance)
balance -= value
fmt.Printf("取 %d 后的余额: %d\n", value, balance)
fmt.Println()
}
func main() {
for i:=0; i < 5; i++ {
go withdraw(500) // 取500
go deposit(500) // 存500
}
for i := 0; i < 10; i++ {
<-sign
}
fmt.Printf("当前余额: %d\n", balance)
}
func init() {
balance = 1000 // 初始账户余额为1000
flag.UintVar(&protecting, "protecting", 0, "是否加锁,0表示不加锁,1表示加锁")
}
上面的代码中,使用了通道来让主 goroutine
等待其他 goroutine
运行结束,每个子goroutine
在运行结束之前向通道发送一个元素,主 goroutine
在最后从这个通道接收元素,接收次数与子goroutine
个数相同。接收完后就会退出主goroutine
。
代码使用协程实现多次(5次)对一个账户进行存钱和取钱的操作,先来看不加锁的情况:
余额: 1000
存 500 后的余额: 1500
余额: 1000
取 500 后的余额: 1000
余额: 1000
存 500 后的余额: 1500
余额: 1000
取 500 后的余额: 1000
余额: 1000
存 500 后的余额: 1500
余额: 1000
取 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 1000
存 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 1000
存 500 后的余额: 1000
当前余额: 1000
可以看到出现了混乱,比如第二次1000的余额取500后还是1000,这种对同一资源的竞争出现了竞态条件(Race Condition
)。
下面来看加锁的执行结果:
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
余额: 1000
存 500 后的余额: 1500
余额: 1500
取 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
当前余额: 1000
加锁后就正常了。
下面介绍更细化的互斥锁:读/写互斥锁RWMutex。
二、读写锁RWMutex
1、RWMutex介绍
读/写互斥锁RWMutex
包含了读锁和写锁,分别对共享资源的“读操作”和“写操作”进行保护。sync.RWMutex
类型中的Lock方法和Unlock
方法分别用于对写锁进行锁定和解锁,而它的RLock
方法和RUnlock
方法则分别用于对读锁进行锁定和解锁。
有了互斥锁Mutex,为什么还需要读写锁呢?因为在很多并发操作中,并发读取占比很大,写操作相对较少,读写锁可以并发读取,这样可以提供服务性能。读写锁具有以下特征:
读写锁 | 读锁 | 写锁 |
---|---|---|
读锁 | Yes | No |
写锁 | No | No |
也就是说,
如果某个共享资源受到读锁和写锁保护时,其它
goroutine
不能进行写操作。换句话说就是读写操作和写写操作不能并行执行,也就是读写互斥;受读锁保护时,可以同时进行多个读操作。
在使用读写锁时,还需要注意:
不要对未锁定的读写锁解锁;
对读锁不能使用写锁解锁
对写锁不能使用读锁解锁
2、RWMutex使用实例
改写前面的取钱和存钱操作,添加查询余额的方法:
package main
import (
"fmt"
"sync"
)
// account 代表计数器。
type account struct {
num uint // 操作次数
balance int // 余额
rwMu *sync.RWMutex // 读写锁
}
var sign = make(chan struct{}, 15) //通道,用于等待所有goroutine
// 查看余额:使用读锁
func (c *account) check() {
defer func() {
sign <- struct{}{}
}()
c.rwMu.RLock()
defer c.rwMu.RUnlock()
fmt.Printf("%d 次操作后的余额: %d\n", c.num, c.balance)
}
// 存钱:写锁
func (c *account) deposit(value int) {
defer func() {
sign <- struct{}{}
}()
c.rwMu.Lock()
defer c.rwMu.Unlock()
fmt.Printf("余额: %d\n", c.balance)
c.num += 1
c.balance += value
fmt.Printf("存 %d 后的余额: %d\n", value, c.balance)
fmt.Println()
}
// 取钱:写锁
func (c *account) withdraw(value int) {
defer func() {
sign <- struct{}{}
}()
c.rwMu.Lock()
defer c.rwMu.Unlock()
fmt.Printf("余额: %d\n", c.balance)
c.num += 1
c.balance -= value
fmt.Printf("取 %d 后的余额: %d\n", value, c.balance)
fmt.Println()
}
func main() {
c := account{0, 1000, new(sync.RWMutex)}
for i:=0; i < 5; i++ {
go c.withdraw(500) // 取500
go c.deposit(500) // 存500
go c.check()
}
for i := 0; i < 15; i++ {
<-sign
}
fmt.Printf("%d 次操作后的余额: %d\n", c.num, c.balance)
}
执行结果:
余额: 1000
取 500 后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
1 次操作后的余额: 500
余额: 500
存 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
余额: 1000
存 500 后的余额: 1500
余额: 1500
取 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
余额: 1000
取 500 后的余额: 500
余额: 500
存 500 后的余额: 1000
10 次操作后的余额: 1000
读写锁和互斥锁的不同之处在于读写锁把对共享资源的读操作和写操作分开了,可以实现更复杂的访问控制。
总结:
读写锁也是一种互斥锁,它是互斥锁的扩展。在使用时需要注意:
加锁后一定要解锁
不要重复加锁或者解锁
不解锁未锁定的锁
不要传递互斥锁
来源:https://www.tuicool.com/articles/YFnIJz7
猜你喜欢
- 正文开始:服务器端代码:# 再来简单的测试,这个是服务器端import socketimport sysBUF_SIZE = 1024ip_
- 1.基本介绍在OpenCV中,图像通道是按照 B 通道→G 通道→R 通道的顺序存储的。在图像处理过程中,可以根据需要对通道进行拆分和合并。
- 大家好,今天我在学习 MySQL 8.0.22安装及配置遇到了一些问题,特地将我整个安装过程分享出来希望可以帮助不会安装的小伙伴😜。参考链接
- 1.表达式操作符Table 1 算术操作符操作符 语法 含义+ a + b 相加 - a - b 相减 - - a
- system默认:managersys默认:change_on_install使用SQL Plus登录数据库时,system使用密码mana
- 本文实例讲述了Python 静态方法和类方法。分享给大家供大家参考,具体如下:1. 类属性、实例属性它们在定义和使用中有所区别,而最本质的区
- 一、实现原理其实实现原理很简单,我们的pptx文件其实是一个压缩包。我们可以直接修改pptx文件的后缀,改成zip然后解压,比如下面这个:这
- 编写XHTML代码的规则要比编写HTML要严格得多,类似下面的代码在HTML中是有效的,但在XHTML中则是无效的。 [javascript
- 传统行业里,缺做互联网资深的人;互联网行业里,缺玩传统业务资深的人。于是会造成很多问题,比如两边难沟通,在传统行业者心目中,网络营销e-Ma
- 引言书接上回 Gradio机器学习模型快速部署工具【quickstart】翻译,讲到多输入输出,其实很简单,就是把多个组件包装到列表,inp
- 本文实例分析了Python字符串格式化输出方法。分享给大家供大家参考,具体如下:我们格式化构建字符串可以有3种方法:1 元组占位符m = &
- 本文实例讲述了微信小程序学习笔记之本地数据缓存功能。分享给大家供大家参考,具体如下:前面介绍了微信小程序获取位置信息操作。这里再来介绍一下微
- 我们可以利用Session对象来进行注册验证。Session对象会帮我们把某一用户的信息保留下来,让后续的网页读取。我们就可以在用户注册成功
- 现在就摘录一下sql2005联机丛书里的关于这几个数据类型的解释字符数据类型(nchar 长度固定,nvarchar 长度可变)和 Unic
- 在Matplotlib实际使用中会有生成不同大小subplots的需求。import numpy as np import matplotl
- 作用域:顾名思义,作用的范围。如果你是自学者,而且已经进军到函数这一部分了,那么就应当了解下Python的作用域。否则你可能会像我一样,总是
- MySQL MEM_ROOT详解这篇文章会详细解说MySQL中使用非常广泛的MEM_ROOT的结构体,同时省去debug部分的信息,仅分析正
- 前言初次了解JWT,很基础,高手勿喷。基于Token的身份验证用来替代传统的cookie+session身份验证方法中的session。to
- Python中的array模块是一个预定义的数组,因此其在内存中占用的空间比标准列表小得多,同时也可以执行快速的元素级别操作,例如添加、删除
- flask多进程会引起重复加载,解决方法:把耗资源的加载挪到函数里面或者类里面,就不会重复加载资源了。测试发现,不是flask引起的,是多进