GoLang并发编程中条件变量sync.Cond的使用
作者:鲲鹏飞九万里 发布时间:2024-04-25 15:28:40
一、条件变量与互斥锁
条件变量是基于互斥锁的,它必须基于互斥锁才能发挥作用;
条件变量并不是用来保护临界区和共享资源的,它是用来协调想要访问共享资源的那些线程的;
在Go语言中,条件变量最大的优势是效率方面的提升。当共享资源不满足条件的时候,想操作它的线程不用循环往返地检查了,只要等待通知就好了。
二、条件变量与互斥锁的配合使用
条件变量的初始化离不开互斥锁,并且它的方法有点也是基于互斥锁的。
条件变量提供的三个方法:等待通知(wait)、单发通知(signal)、广发通知(broadcast)。
三、条件变量的使用
创建锁和条件
// mailbox 代表信箱
// 0 代表信箱是空的,1代表信箱是满的
var mailbox uint8
// lock 代表信箱上的锁
var lock sync.RWMutex
// sendCond 代表专用于发信的条件变量
var sendCond = sync.NewCond(&lock)
// reveCond 代表专用于收信的条件变量
var reveCond = sync.NewCond(lock.RLocker())
sync.Cond
类型并不是开箱即用的,只能利用sync.NewCond
创建它的指针值。这个函数需要sync.Locker
类型的参数值。sync.Locker
是一个接口,它包含两个指针方法,即Lock()
和Unlock()
;因此,sync.Mutex
和sync.RWMutex
这两个类型的指针类型才是sync.Locker
接口的实现类型。上面lock变量的Lock方法和Unlock方法分别用于对其中写锁的锁定和解锁,它们与sendCond变量的含义对应。
lock.RLocker()
得到的值,拥有Lock和Unlock方法,其内部会分别调用lock变量的RLock方法和RUnlock方法;
使用
lock.Lock()
for mailbox == 1 {
sendCond.Wait()
}
mailbox = 1
lock.Unlock()
recvCond.Signal()
lock.RLock()
for mailbox == 0 {
recvCond.Wait()
}
mailbox = 0
lock.RUnlock()
sendCond.Signal()
完整代码:
package main
import (
"log"
"sync"
"time"
)
func main() {
// mailbox 代表信箱
// 0 代表信箱是空的,1代表信箱是满的
var mailbox uint8
// lock 代表信箱上的锁
var lock sync.RWMutex
// sendCond 代表专用于发信的条件变量
var sendCond = sync.NewCond(&lock)
// reveCond 代表专用于收信的条件变量
var reveCond = sync.NewCond(lock.RLocker())
// sign 用于传递演示完成的信号
sign := make(chan struct{}, 2)
max := 5
go func(max int) { // 用于发信
defer func() {
sign <- struct{}{}
}()
for i := 1; i <= max; i++ {
time.Sleep(time.Millisecond * 5)
lock.Lock()
for mailbox == 1 {
sendCond.Wait()
}
log.Printf("sender [%d]: the mailbox is empty.", i)
mailbox = 1
log.Printf("sender [%d]: the letter has been sent.", i)
lock.Unlock()
reveCond.Signal()
}
}(max)
go func(max int) { // 用于收信
defer func() {
sign <- struct{}{}
}()
for j := 1; j <= max; j++ {
time.Sleep(time.Millisecond * 500)
lock.RLock()
for mailbox == 0 {
reveCond.Wait()
}
log.Printf("receiver [%d]: the mailbox is full.", j)
mailbox = 0
log.Printf("receiver [%d]: the letter has been received.", j)
lock.RUnlock()
sendCond.Signal()
}
}(max)
<-sign
<-sign
}
四、条件变量的Wait方法做了什么
(1)条件变量Wait方法主要做的四件事
条件变量的Wait方法主要做了四件事:
把调用它的goroutine(也就是当前goroutine)加入到当前条件变量的通知队列中;
解锁当前条件变量基于的那个互斥锁;
让当前的goroutine处于等待状态,等到通知到来时再决定是否唤醒它。此时,这个goroutine就会阻塞在调用这个Wait方法的那行代码上;
如果通知到来并决定唤醒这个goroutine,那么就在唤醒它之后重新锁定当前条件变量基于的互斥锁。自此以后,当前的goroutine就会继续执行后面的代码了。
(2)为什么要先要锁定条件变量基于的互斥锁,才能调用它的wait方法
因为条件变量的wait方法在阻塞当前的goroutine之前,会解锁它基于的互斥锁。所以在调用wait方法之前,必须先锁定这个互斥锁,否则在调用这个wait方法时,就会引发一个不可恢复的panic。
如果条件变量的Wait方法不先解锁互斥锁的话,那就会造成两个后果:不是当前的程序因panic而崩溃,就是相关的goroutine全面阻塞。
(3)为什么用for语句来包裹调用的wait方法表达式,用if语句不行吗
if语句只会对共享资源的状态检查一次,而for语句却可以做多次检查,直到这个状态改变为止。
之所以做多次检查,主要是为了保险起见。如果一个goroutine因收到通知而被唤醒,但却发现共享资源的状态,依然不符合它的要求i,那么就应该再次调用条件变量的Wait方法,并继续等待下次通知的到来。
这种情况是很有可能发生的,具体如下面所示:
有多个 goroutine 在等待共享资源的同一种状态。比如,它们都在等mailbox变量的值不为0的时候再把它的值变为0,这就相当于有多个人在等着我向信箱里放置情报。虽然等待的 goroutine 有多个,但每次成功的 goroutine 却只可能有一个。别忘了,条件变量的Wait方法会在当前的 goroutine 醒来后先重新锁定那个互斥锁。在成功的 goroutine 最终解锁互斥锁之后,其他的 goroutine 会先后进入临界区,但它们会发现共享资源的状态依然不是它们想要的。这个时候,for循环就很有必要了。
共享资源可能有的状态不是两个,而是更多。比如,mailbox变量的可能值不只有0和1,还有2、3、4。这种情况下,由于状态在每次改变后的结果只可能有一个,所以,在设计合理的前提下,单一的结果一定不可能满足所有 goroutine 的条件。那些未被满足的 goroutine 显然还需要继续等待和检查。
有一种可能,共享资源的状态只有两个,并且每种状态都只有一个 goroutine 在关注,就像我们在主问题当中实现的那个例子那样。不过,即使是这样,使用for语句仍然是有必要的。原因是,在一些多 CPU 核心的计算机系统中,即使没有收到条件变量的通知,调用其Wait方法的 goroutine 也是有可能被唤醒的。这是由计算机硬件层面决定的,即使是操作系统(比如 Linux)本身提供的条件变量也会如此。
综上所述,在包裹条件变量的Wait方法的时候,我们总是应该使用for语句。
不要用if语句,因为它不能重复地执行“检查状态 - 等待通知 - 被唤醒”的这个流程。
(4)条件变量的Signal方法和Broadcast方法
条件变量signal方法和Broadcast方法都是用来发送通知的,不同的是,前者的通知只会唤醒一个因此而等待的goroutine,而后者的通知却会唤醒所有为此等待的goroutine。
条件变量的Wait方法总会把当前的 goroutine 添加到通知队列的队尾,而它的Signal方法总会从通知队列的队首开始,查找可被唤醒的 goroutine。所以,因Signal方法的通知,而被唤醒的 goroutine 一般都是最早等待的那一个。
条件变量Signal方法和Broadcast方法放置的位置:
与Wait方法不同,条件变量的Signal方法和Broadcast方法并不需要在互斥锁的保护下执行。恰恰相反,我们最好在解锁条件变量基于的那个互斥锁之后,再去调用它的这两个方法。这更有利于程序的运行效率。
条件变量的通知具有即时性:
如果发送通知的时候没有 goroutine 为此等待,那么该通知就会被直接丢弃。在这之后才开始等待的 goroutine 只可能被后面的通知唤醒。
来源:https://blog.csdn.net/hefrankeleyn/article/details/128602812
猜你喜欢
- 环境搭建1、下载所需的软件包:(1)python安装包(2)django安装包以下2个包其实是安装python包管理工具,在后面安装djan
- (5)SELECT (5-2) DISTINCT(5-3)TOP(<top_specification>)(5-1) <s
- 生活中,我们在登录微博,邮箱的时候,常常会碰到验证码。在工作时,如果想要爬取一些数据,也会碰到验证码的阻碍。本次试验将带领大家认识验证码的一
- 前言本文主要介绍了关于MySQL主键为0与主键自排约束的关系,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧。开始不设置主键
- 在 linux 系统中连接 mdb 数据库,直接连接的话,mdb 默认的驱动无法识别非 windows 的路径, 所以不能使用常规的连接方式
- 操作系统:Windows10 64bitPython版本:3.8.0下载地址:https://www.python.org/download
- 1、准备工作1.1 库介绍只有登录微信才能获取到微信好友的信息,本文采用wxpy该第三方库进行微信的登录以及信息的获取。wxpy 在 itc
- 一、介绍我们在项目的开发过程中应该会遇到这样的问题:我们的项目读取某个配置文件,然后才能按照配置的信息正常运行服务,当我们需要对修改服务的某
- 1、Python的min函数返回列表中的最小的项。2、如何返回列表中最小的项的索引?def indexofMin(arr):
- 方法一:def str_count(str): '''找出字符串中的中英文、空格、数字、标点符号个数'
- MySQL是支持在单个查询字符串中指定多语句执行的,使用方法是给链接指定参数: //链接时设定 mysql_real_connect( ..
- 下面这个函数使用FSO对象来判断服务器上的某个文件是否存在:<%Private Function Dir(byVa
- 有些 MySQL 数据表中可能存在重复的记录,有些情况我们允许重复数据的存在,但有时候我们也需要删除这些重复的数据。本章节我们将为大家介绍如
- 本文实例讲述了Pytorch实现的手写数字mnist识别功能。分享给大家供大家参考,具体如下:import torchimport torc
- 目录一、简单字段定义1、定义 Schema 并生成 Parquet 文件2、验证 Parquet 数据文件二、含嵌套字段定义1、验证 Par
- 井字棋,英文名叫Tic-Tac-Toe,是一种在3*3格子上进行的连珠游戏,和五子棋类似,由于棋盘一般不画边框,格线排成井字故得名。游戏需要
- 本文实例讲述了Python求解平方根的方法。分享给大家供大家参考。具体如下:主要通过SICP的内容改写而来。基于newton method求
- 基本命令显示版本信息pip -V安装指定包pip install <packages>pip install -i 'h
- 一、字符编码简史:美国:1963年 ASCII (包含127个字符 占1个字节)中国:1980年 GB2312 (收录7445个
- 二进制日志二进制日志中以“事件”的形式记录了数据库中数据的变化情况,对于MySQL数据库的灾难恢复起