pthread_cond_wait的spurious wakeup问题
最近在温习pthread的时候,忽然发现以前对pthread_cond_wait的了解太肤浅了。昨晚在看《Programming With POSIX Threads》的时候,看到了pthread_cond_wait的通常使用方法:
pthread_mutex_lock();
while(condition_is_false)
pthread_cond_wait();
pthread_mutex_unlock();
为什么在pthread_cond_wait()前要加一个while循环来判断条件是否为假呢?
APUE中写道:
传递给pthread_cond_wait的互斥量对条件进行保护,调用者把锁住的互斥量传给函数。函数把调用线程放到等待条件的线程列表上,然后对互斥量解锁,这两个操作是原子操作。
线程释放互斥量,等待其他线程发给该条件变量的信号(唤醒一个等待者)或广播该条件变量(唤醒所有等待者)。当等待条件变量时,互斥量必须始终为释放的,这样其他线程才有机会锁住互斥量,修改条件变量。当线程从条件变量等待中醒来时,它重新继续锁住互斥量,对临界资源进行处理。
条件变量的作用是发信号,而不是互斥。
wait前检查
对于多线程程序,不能够用常规串行的思路来思考它们,因为它们是完全异步的,会出现很多临界情况。比如:pthread_cond_signal的时间早于pthread_cond_wait的时间,这样pthread_cond_wait就会一直等下去,漏掉了之前的条件变化。
对于这种情况,解决的方法是在锁住互斥量之后和等待条件变量之前,检查条件变量是否已经发生变化。
if(condition_is_false)
pthread_cond_wait();
这样在等待条件变量前检查一下条件变量的值,如果条件变量已经发生了变化,那么就没有必要进行等待了,可以直接进行处理。这种方法在并发系统中比较常见,例如之前PACKET_MMAP中poll的竞争条件的解决方法。
-----------------------------------------------------------------------
忽然想起了设计模式中的单件模式的"双重检查加锁":
Singleton *getInstance()
{
if(ptr==NULL)
{
LOCK();
if(ptr==NULL)
{
ptr = new Singleton();
}
UNLOCK();
}
return ptr;
}
这样只有在第一次的时候会进行锁(应该是第一轮,如果刚开始有多个线程进入了最上层的ptr==NULL代码块,就会有多次锁,只不过之后就不会锁了),之后就不会锁了。
pthread_once()的实现也是基于单件模式的。
pthread_once函数首先检查控制变量,以判断是否已经完成初始化。如果完成,pthread_once简单的返回;否则,pthread_once调用初始化函数(没有参数),并记录下初始化被完成。如果在一个线程初始化时,另外的线程调用pthread_once,则调用线程将等待,直到那个线程完成初始化后返回。换句话,当调用pthread_once成功返回时,调用者能够肯定所有的状态已经初始化完毕。
int
__pthread_once (once_control, init_routine)
pthread_once_t *once_control;
void (*init_routine) (void);
{
/* XXX Depending on whether the LOCK_IN_ONCE_T is defined use a
global lock variable or one which is part of the pthread_once_t
object. */
if (*once_control == PTHREAD_ONCE_INIT)
{
lll_lock (once_lock, LLL_PRIVATE);
/* XXX This implementation is not complete. It doesn't take
cancelation and fork into account. */
if (*once_control == PTHREAD_ONCE_INIT)
{
init_routine ();
*once_control = !PTHREAD_ONCE_INIT;
}
lll_unlock (once_lock, LLL_PRIVATE);
}
return 0;
}
-----------------------------------------------------------------------
pthread_cond_wait中的while()不仅仅在等待条件变量前检查条件变量,实际上在等待条件变量后也检查条件变量。pthread_cond_wait返回后,还需要检查条件变量,这是为什么呢?难道pthread_cond_wait不是pthread_cond_signal触发了某个condition导致的吗?
这个地方有些迷惑人,实际上pthread_cond_wait的返回不仅仅是pthread_cond_signal和pthread_cond_broadcast导致的,还会有一些假唤醒,也就是spurious wakeup。
何为假唤醒?顾名思义就是虚假的唤醒,与pthread_cond_signal和pthread_cond_broadcast的唤醒相对。那么什么情况下会导致假唤醒呢?可以阅读参考1。
signal
大致意思是:
在linux中,pthread_cond_wait底层是futex系统调用。在linux中,任何慢速的阻塞的系统调用当接收到信号的时候,就会返回-1,并且设置errno为EINTR。在系统调用返回前,用户程序注册的信号处理函数会被调用处理。
注:什么有样的系统调用会出现接收信号后发挥EINTR呢?
慢速阻塞的系统调用,有可能会永远阻塞下去的那种。当接收到信号的时候,认为是一个返回并执行其他代码的一个时机。
信号的处理也不简单,因为有些慢系统调用被信号中断后是会自动重启的,所以我们通常需要用siginterrupt(signo, 1)来关闭重启或者在用sigaction安装信号处理函数的时候取消SA_RESTART标志,之后就可以通过判断信号的返回值是否是-1和errno是否为EINTR来判断是否有信号抵达。
如果关闭了SA_RESTART的一些使用慢速系统调用的应用,一般都采用while()循环,检测到EINTR后就重新调用。
while(1)
{
int ret = syscall();
if(ret<0 && errno==EINTR)
continue;
else
break;
}
但是,对于futex这种方法不行,因为futex结束后,再重新运行的过程中,会出现一个时间窗口,其他线程可能会在这个时间窗口中进行pthread_cond_signal,这样,再进行pthread_cond_wait的时候就丢失了一次条件变量的变化。解决方法就是在pthread_cond_wait前检查条件变量,也就是
pthread_mutex_lock();
while(condition_is_false)
pthread_cond_wait();
pthread_mutex_unlock();
pthread_cond_broadcast
实际上,不仅仅信号会导致假唤醒,pthread_cond_broadcast也会导致假唤醒。加入条件变量上有多个线程在等待,pthread_cond_broadcast会唤醒所有的等待线程,而pthread_cond_signal只会唤醒其中一个等待线程。这样,pthread_cond_broadcast的情况也许要在pthread_cond_wait前使用while循环来检查条件变量。
参考:
http://vladimir_prus.blogspot.com/2005/07/spurious-wakeups.html
http://www.lambdacs.com/cpt/FAQ.html#Q94
http://groups.google.de/group/comp.programming.threads/msg/bb8299804652fdd7
http://www.win.tue.nl/~aeb/linux/lk/lk-4.html#ss4.5
http://blog.chinaunix.net/u/5251/showart_309061.html
pthread_cond_wait的spurious wakeup问题相关推荐
- linux虚假唤醒(spurious wakeup)
1.Linux对虚假唤醒的说明 On a multi-processor, it may be impossible for an implementation of pthread_cond_sig ...
- java suprious wakeup_多线程编程中条件变量和的spurious wakeup 虚假唤醒
1. 概述 条件变量(condition variable)是利用共享的变量进行线程之间同步的一种机制.典型的场景包括生产者-消费者模型,线程池实现等. 对条件变量的使用包括两个动作: 1)线程等待某 ...
- 多线程并发编程需要注意虚假唤醒Spurious wakeup
虚假唤醒 Spurious wakeup 如果等待线程在没有通知被调用的情况下唤醒,则称为Spurious wakeup. 解决方案就是: 使用while条件判断,更好的方案是避免使用wait这种低 ...
- [C++11 多线程同步] --- 条件变量的那些坑【条件变量信号丢失和条件变量虚假唤醒(spurious wakeup)】
1 条件变量的信号丢失 1.1 条件变量的信号丢失场景重现 拿生产者和消费者模型举例,看一段示例代码: #include <iostream> #include <vector> ...
- 对条件变量(condition variable)的讨论
作者:王东 1.1 什么是条件变量和条件等待? 简单的说: 条件变量(condition variable)是利用线程间共享的全局变量进行同步的一种机制,主要包括两个动作:一个线程等待某个 ...
- Linux多线程实践(8) --Posix条件变量解决生产者消费者问题
Posix条件变量 int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr); int pthread_co ...
- 全面总结:进程与线程
首先,进程和线程的区别: 根本区别:进程是操作系统资源分配的基本单位,而线程是任务调度和执行的基本单位 在开销方面:每个进程都有独立的地址空间,进程之间的切换会有较大的开销:线程可以看做轻量级的进程, ...
- 系统进程间的同步机制
说出你所知道的各类linux系统的各类同步机制(重点),什么是死锁?如何避免死锁 linux系统的通讯机制,主要是指进程间通讯,其实通讯就是进程同步的手段.如果问进程间同步,见问题7,这里要说的lin ...
- Java的LockSupport.park()实现分析
LockSupport类是Java6(JSR166-JUC)引入的一个类,提供了基本的线程同步原语.LockSupport实际上是调用了Unsafe类里的函数,归结到Unsafe里,只有两个函数: p ...
最新文章
- Eclipse中SVN设置文件为ignore后重新添加至版本控制
- 3000 字推荐一个可视化神器,50 行 Python 代码制作数据大屏
- ThinkPHP快捷方法使用总结
- ExecutorService框架
- 用MATLAB作图像识别所需要注意的细节!
- BAT 面试Java技术问题总结
- redis java 遍历key_java遍历读取整个redis数据库实例
- SEM竞价员怎么分析竞争对手,需要分析哪些?
- 进阶 09 Map集合
- java案例4-5图形的面积与周长计算程序
- 神经网络训练的一些方法
- 【AE】2 ICommand和ITool
- 怎样和控制欲很强的家人相处-不受他人影响
- JavaCV音视频开发宝典:JavaCV使用gdigrab方式实现windows录屏(windows屏幕画面抓取/采集,可实现高帧率屏幕截屏、录屏功能)
- 几种常用的mosfet驱动电路
- iphone文件访问ftp服务器,ipad ftp服务器 iPhone/iPad访问FTP服务器设置步骤
- python - alipay sdk 使用 及 注意点
- 斯坦福SCI论文写作课笔记(十三)
- Glide.Placeholder(loadingImage) 之后 Glide 载图片不显示问题
- matlab工具箱中英对照,MATLABa工具包中英对照
热门文章
- centos7部署nodejs新版
- 小红帽怎样装图形化界面_纯技术篇:U盘装系统,不再多花冤枉钱
- java基础面试题整理(BAT)
- IDEA2020安装
- mysql 数据库表锁死_mysql 数据库表被锁住了_Mysql数据库表锁死如何处理?
- win10安装mudbox失败,怎么强力卸载删除注册表并重新安装
- [Docker]Docker拉取,上传镜像到Harbor仓库
- 2016年4月 之 《C程序设计语言》
- .NET操作Excel
- [dp] LeetCode 62. Unique Paths