Go并发同步Mutex典型易错使用场景
作者:BeCautious 发布时间:2024-05-02 16:23:54
Mutex的4种易错使用场景
1.Lock/Unlock 不成对出现
Lock/Unlock 没有成对出现,就可能会出现死锁或者是因为Unlock一个未加锁的Mutex而导致 panic。
忘记Unlock的情形
代码中有太多的 if-else 分支,可能在某个分支中漏写了 Unlock;
在重构的时候把 Unlock 给删除了;
Unlock 误写成了 Lock。
忘记Lock的情形一般是误删除了或者注释掉了Lock。
eg:
func main() {
var mu sync.Mutex
defer mu.Unlock()
fmt.Println("oh, missing Lock!")
}
error result:
2.Copy 已使用的 Mutex
实际上sync包下的同步原语在使用后都是不可复制的,原因在于Mutex是有状态的,其state的值时刻在变化,如果复制一个已经加锁的Metux对象给一个新的变量,可能这个变量刚初始化就显示被加锁了,这显然是不合理的。
eg:以下代码在调用 foo 函数的时候,调用者会复制 Mutex 变量 c 作为 foo 函数的参数,不幸的是,复制之前已经使用了这个锁,这就导致,复制的 Counter 是一个带状态 Counter,从而会导致死锁。
type Counter struct {
sync.Mutex
Count int
}
func main() {
var c Counter
c.Lock()
defer c.Unlock()
c.Count++
foo(c) // 复制锁
}
// 这里Counter的参数是通过复制的方式传入的
func foo(c Counter) {
c.Lock()
defer c.Unlock()
fmt.Println("in foo")
}
error result:还好有Go的协程死锁检查机制,程序运行后会快速失败而不是一直hang住。
Go Vet指令
我们当然不想程序运行了才发现死锁,我们可以通过go vet指令来在运行前检查我们的代码是否存在lock copy问题:
检查原理
检查是通过copylock分析器静态分析实现的。这个分析器会分析函数调用、range 遍历、复制、声明、函数返回值等位置,有没有锁的值 copy 的情景,以此来判断有没有问题。
通过源码我们可以看到实现了Lock或者Unlock接口的struct都支持copylock检查。
var lockerType *types.Interface
// Construct a sync.Locker interface type.
func init() {
nullary := types.NewSignature(nil, nil, nil, false) // func()
methods := []*types.Func{
types.NewFunc(token.NoPos, nil, "Lock", nullary),
types.NewFunc(token.NoPos, nil, "Unlock", nullary),
}
lockerType = types.NewInterface(methods, nil).Complete()
}
3.重入
Mutex不像Java中的ReentrantLock拥有可重入的功能,主要是因为其实现中没有标记位记录哪个goroutine 拥有这把锁,所以Mutex是一个不可重入锁,而一旦误用Mutex的重入就会报错。
eg:
func foo(l sync.Locker) {
fmt.Println("in foo")
l.Lock()
bar(l)
l.Unlock()
}
func bar(l sync.Locker) {
l.Lock()
fmt.Println("in bar")
l.Unlock()
}
func main() {
l := &sync.Mutex{}
foo(l)
}
error result:我们可以看到当在bar方法中尝试再次获取锁时,获取不到,触发了死锁。
4.死锁
两个或两个以上的进程(或线程,goroutine)
执行过程中,因争夺共享资源而处于一种互相等待的状态,如果没有外部干涉,它们都将无法推进下去,此时,我们称系统处于死锁状态或系统产生了死锁。
死锁产生的4个必要条件
如果想避免死锁,我们只要思考如何打破以下任意条件就可以。
1.互斥: 至少一个资源是被排他性独享的,其他线程必须处于等待状态,直到资源被释放。
2.持有和等待:goroutine 持有一个资源,并且还在请求其它 goroutine 持有的资源,也就是咱们常说的“吃着碗里,看着锅里”的意思。
3. 不可剥夺:资源只能由持有它的 goroutine 来释放。
4.环路等待:一般来说,存在一组等待进程,P={P1,P2,…,PN},P1 等待 P2 持有的
资源,P2 等待 P3 持有的资源,依此类推,最后是 PN 等待 P1 持有的资源,这就形成
了一个环路等待的死结。
eg:在这里我们以办理居住证业务,举一个简单的环路等待导致死锁的例子:
//办理居住证
func main() {
// 网签中心证明
var psCertificate sync.Mutex
// 社区证明
var propertyCertificate sync.Mutex
var wg sync.WaitGroup
wg.Add(2) // 需要网签中心和社区都处理
// 网签中心处理goroutine
go func() {
defer wg.Done() // 网签中心处理完成
psCertificate.Lock()
defer psCertificate.Unlock()
// 检查材料
time.Sleep(5 * time.Second)
// 请求社区的证明
propertyCertificate.Lock()
propertyCertificate.Unlock()
}()
// 社区处理goroutine
go func() {
defer wg.Done() // 社区处理完成
propertyCertificate.Lock()
defer propertyCertificate.Unlock()
// 检查材料
time.Sleep(5 * time.Second)
// 请求网签中心的证明
psCertificate.Lock()
psCertificate.Unlock()
}()
wg.Wait()
fmt.Println("成功完成")
}
error result:
解决策略
1.可以引入一个第三方的锁,大家都依赖这个锁进行业务处理,比如现在政府推行的一站式政务服务中心。
2.解决持有等待问题,比如社区不需要看到网签中心的证明才给开居住证明。
来源:https://juejin.cn/post/7101531692698959886
猜你喜欢
- 其实小程序上面也可以使用 echart 等开源图表库得,而且支持代码包得裁切功能,但是可能我不会用吧,效果不太好,而且我这就一个图,也没什么
- 1. 前言相信参与使用Oracle数据库进行项目开发、运维的同学常常被Oracle JDBC驱动的Maven依赖折磨。现在这一情况在今年二月
- 1.找到python的安装路径: 如果忘记可以在Pycharm运行如下代码:import
- 一起画图吧为什么突然想搞这个画图软件呢不瞒各位,是因为最近接到了一个很小很小很小小得不能再小的小项目就是基于Tkinter,做一个简易的画图
- 自己最近有在学习python,这实在是一门非常短小精悍的语言,很喜欢这种语言精悍背后又有强大函数库支撑的语言。可是刚接触不久就遇到了让人头疼
- 目录0 背景说明0.1 获取AccessToken0.2 数据库查询0.3 文件下载2. 简单的封装3. 简单测试4. 参考文档0 背景说明
- 前言对于pprof,相信熟悉go语言的程序员基本都不陌生,一般线上的问题都是靠它可以快速定位。但是实际项目中,很多时候我们为了性能都不会开启
- 如何显示一个文本文件?完整显示文本文件的代码如下: Write(STRING) WriteLine(STRING) WriteBlan
- 可以用作一些资源的释放。1.在一个函数内的defer执行顺序是先写的后执行,后写的先执行(遵循栈结构)func DeferTest1(){
- 业务的开发时候有一个需求,需要对比当前时间段和去年同星期的时间段的数据,例如当前时间是2019-04-11,是今年的第十五周的周四,如何去取
- 注意: 在搭建网络的时候用carpool2D的时候,让高度和宽度方向不同池化时,用如下:nn.MaxPool2d(kernel_size=2
- 1.匿名函数介绍匿名函数指一类无须定义标识符的函数或子程序。Python用lambda语法定义匿名函数,只需用表达式而无需申明。在pytho
- 目录1. 输入、输出与注释1.1 获取用户输入1.2 格式化输出1.2.1 基本方法1.2.2 format 格式化函数1.3 注释2. 高
- asp之家注:对于ACCESS数据库中的NULL,经常我们直接判断该字段是否为空用的是:name="",但是这个还不够,
- 我的世界小游戏使用方法:移动前进:W,后退:S,向左:A,向右:D,环顾四周:鼠标,跳起:空格键,切换飞行模式:Tab;选择建筑材料砖:1,
- Numpy学习1 Numpy 介绍与应用1-1Numpy是什么NumPy 是一个运行速度非常快的数学库,一个开源的的python科学计算库,
- 最近再写openpose,它的网络结构是多阶段的网络,所以写网络的时候很想用列表的方式,但是直接使用列表不能将网络中相应的部分放入到cuda
- 本文实例为大家分享了python实现QQ空间自动点赞的具体代码,供大家参考,具体内容如下项目github地址使用python实现qq空间自动
- 数据库(database)MySQL 是最流行的开源数据库系统,可运行于几乎所有的操作系统平台。在《MySQL 安装》一文中详解介绍了安装步
- 前言最近因为工作的需要,在写一些python脚本,总是使用print来打印信息感觉很low,所以抽空研究了一下python的logging库