Go语言并发编程 互斥锁详情
作者:测试开发小记 发布时间:2024-02-02 04:58:30
目录
1、互斥锁Mutex
1.1 Mutex介绍
1.2 Mutex使用实例
2、读写锁RWMutex
2.1 RWMutex介绍
2.2 RWMutex使用实例
1、互斥锁Mutex
1.1 Mutex介绍
Go
语言的同步工具主要由 sync
包提供,互斥锁 (Mutex
) 与读写锁 (RWMutex
) 就是sync
包中的方法。
互斥锁可以用来保护一个临界区,保证同一时刻只有一个 goroutine
处于该临界区内。主要包括锁定(Lock
方法)和解锁(Unlock
方法)两个操作,首先对进入临界区的goroutine
进行锁定,离开时进行解锁。
使用互斥锁 (Mutex)时要注意以下几点:
不要重复锁定互斥锁,否则会阻塞,也可能会导致死锁(
deadlock
);要对互斥锁进行解锁,这也是为了避免重复锁定;
不要对未锁定或者已解锁的互斥锁解锁;
不要在多个函数之间直接传递互斥锁,
sync.Mutex
类型属于值类型,将它传给一个函数时,会产生一个副本,在函数中对锁的操作不会影响原锁
总之,一个互斥锁只用来保护一个临界区,加锁后记得解锁,对于每一个锁定操作,都要有且只有一个对应的解锁操作,也就是加锁和解锁要成对出现,最保险的做法时使用defer
语句解锁。
1.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
。
2、读写锁RWMutex
2.1 RWMutex介绍
读/写互斥锁RWMutex
包含了读锁和写锁,分别对共享资源的“读操作”和“写操作”进行保护。sync.RWMutex
类型中的Lock
方法和Unlock
方法分别用于对写锁进行锁定和解锁,而它的RLock
方法和RUnlock
方法则分别用于对读锁进行锁定和解锁。
有了互斥锁Mutex
,为什么还需要读写锁呢?因为在很多并发操作中,并发读取占比很大,写操作相对较少,读写锁可以并发读取,这样可以提供服务性能。读写锁具有以下特征:
读写锁 | 读锁 | 写锁 |
---|---|---|
读锁 | Yes | No |
写锁 | No | No |
也就是说:
如果某个共享资源受到读锁和写锁保护时,其它
goroutine
不能进行写操作。换句话说就是读写操作和写写操作不能并行执行,也就是读写互斥;受读锁保护时,可以同时进行多个读操作。
在使用读写锁时,还需要注意:
不要对未锁定的读写锁解锁;
对读锁不能使用写锁解锁
对写锁不能使用读锁解锁
2.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 后的余额: 5001 次操作后的余额: 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 后的余额: 100010 次操作后的余额: 1000
读写锁和互斥锁的不同之处在于读写锁把对共享资源的读操作和写操作分开了,可以实现更复杂的访问控制。
总结:
读写锁也是一种互斥锁,它是互斥锁的扩展。在使用时需要注意:
加锁后一定要解锁
不要重复加锁或者解锁
不解锁未锁定的锁
不要传递互斥锁
来源:https://blog.csdn.net/u010698107/article/details/120248679
猜你喜欢
- 本文为大家分享了Eclipse开发python脚本的具体方法,供大家参考,具体内容如下一、安装python1.访问网址,可以看到如下图所示界
- 在函数参数中乱用表达式作为默认值Python允许给一个函数的某个参数设置默认值以使该参数成为一个可选参数。尽管这是这门语言很棒的一个功能,但
- python中查找指定的字符串的方法如下:code#查询def selStr(): sStr1 = 'jsjtt.com
- 1.0简介三维图像技术是现在国际最先进的计算机展示技术之一,任何普通电脑只需要安装一个插件,就可以在网络浏览器中呈现三维的产品,不但逼真,而
- fckconfig.js 中修改 添加 FCKConfig.LineHeights = '100%;150%;200%;250%;3
- 前面我讲解了如何将树莓派(Raspberry Pi)打造成无线路由,感觉每次通过命令ssh管理显麻烦,于是自己动手编写Web界面,主要是使用
- 开发环境集成开发工具:jupyter notebook 6.5.2集成开发环境:Python 3.10.6第三方库:to
- 根据用户权限设定用户可以访问哪些页面,用django实现一个简单的demo。1.models.py 文件class level(models
- 在之前的工作中,业务方做了一些调整,提出了对一部分核心指标做更细致的拆分并定期产出的需求。出于某些原因,这部分数据不太方便在报表上呈现,因此
- 1.%格式符name = '李四'age = 18a = "姓名:%s,年龄:%s"%(name,age
- 先安装第三方库:pip install requestsdef isConnected(): import requ
- osql 工具是一个 Microsoft Windows 32 命令提示符工具,您可以使用它运行 Transact-SQL 语句和脚本文件。
- 什么是MySql数据库?通常意义上,数据库也就是数据的集合,具体到计算机上数据库可以是存储器上一些文件的集合或者一些内存数据的集合。我们通常
- 运行效果:完整代码from tkinter import *def click(num): global op op
- 本文研究的主要是PyQt5主窗口动态加载Widget的代码示例,具体如下。我们通过Qt Designer设计两个窗口,命名为主窗口(Main
- 一、浏览器允许每个域名所包含的 cookie 数:Microsoft 指出 Internet Explorer 8 增加 cookie 限制
- 本文实例讲述了Yii开启片段缓存的方法。分享给大家供大家参考,具体如下:1、main.php文件中的components中添加:cache&
- 背景一直以来,中式占卜都是基于算命先生手工实现,程序繁琐(往往需要沐浴、计算天时、静心等等流程)。准备工作复杂(通常需要铜钱等道具),计算方
- 使用python生成一个图片验证码,随机的,可以由于验证人机和别的啊,很方便很简单导入模块import randomfrom PIL imp
- Java基础—学生信息管理系统(使用数据库),供大家参考,具体内容如下前一段时间写了学生信息管理系统(使用ArrayLi