条件变量之虚假唤醒

条件变量之虚假唤醒引言当我们使用互斥量(Mutex)与条件变量(condition_variable)进行多线程同步时有可能会产生虚假唤醒现象, 那么究竟什么是虚

欢迎大家来到IT世界,在知识的湖畔探索吧!

条件变量之虚假唤醒

引言

当我们使用互斥量(Mutex)与条件变量(condition_variable)进行多线程同步时有可能会产生虚假唤醒现象, 那么究竟什么是虚假唤醒,它会在什么情况下被触发,什么情况下无需考虑虚假唤醒,如何避免?

1.什么是虚假唤醒?

Linux帮助中有提到

在多核处理器下,pthread_cond_signal可能会激活多于一个线程(阻塞在条件变量上的线程)。结果是,当一个线程调用pthread_cond_signal()后,多个调用pthread_cond_wait()或pthread_cond_timedwait()的线程返回。这种效应成为”虚假唤醒”(spurious wakeup)

通俗点的解释就是:

你(消费线程)收到了其他线程(生产)传来的唤醒信号,但是你唤醒后发现别的消费线程处理的比你快,此时没有数据被可以用于操作,这种情况的发生是预期之外的,称之为虚假唤醒。

2.什么情况下会发生虚假唤醒

以以下C++代码举例。

#include <iostream>

#include <condition_variable>

#include <mutex>

#include <thread>

#include <unistd.h>

#include <assert.h>

#include <queue>

using namespace std;

#define PRODUCTER_NUM 10

#define CONSUMER_NUM 100

std::mutex mutexForProduct;

static queue<unsigned> queueForProduct;

unsigned uProductTotalNum = 0;

condition_variable condVal;

//生产线程

void ConsumerFunction(unsigned threadIndex)

{

while(1)

{

unique_lock<mutex> locker(mutexForProduct);

if(queueForProduct.empty())

{

condVal.wait(locker);

}

if(queueForProduct.empty())

{

printf(“Consumer[%02u] Want To Buy Product, But There is not remain Product”, threadIndex);

assert(false);

}

unsigned productIndex = queueForProduct.front();

printf(“Consumer[%02u] Buying Product[%06u], RemainSize= %lu\n”, threadIndex, productIndex, queueForProduct.size());

queueForProduct.pop();

}

}

//消费线程

void ProducerFunction()

{

while(1)

{

usleep(100 * 1000);

unique_lock<mutex> locker(mutexForProduct);

queueForProduct.push(++uProductTotalNum);

condVal.notify_one();

}

}

int main()

{

for(unsigned i = 0; i < CONSUMER_NUM; i++)

thread(&ConsumerFunction, i).detach();

for(unsigned i = 0; i < PRODUCTER_NUM; i++)

thread(&ProducerFunction).detach();

sleep(3600);

return 0;

}

(1) 当消费者的数量(CONSUMER_NUM)为1时没有其他线程竞争队列,不会触发虚假唤醒。

(2) 当生产者的数量(PRODUCTER_NUM)为1时,

当使用notify_one通知消费线程时,不会发生虚假唤醒,因为每次只会有一个消费者线程收到信号被唤醒,在产品被消耗掉之前不会有新的信号发出来。

当使用notify_all通知消费线程时,会发生虚假唤醒,会有多个消费者线程收到信号被唤醒,当一个线程被唤醒之前,可能其他线程先被唤醒先持有锁,将产品消耗掉。

(3) 当生产者的数量(PRODUCTER_NUM)大于1时,无论是使用notify_one,或者是notify_all都会发生虚假唤醒,当多个生产者使用notify_one时,多个线程被唤醒,有可能其中一个处理的特别快,将所有的数据都处理完毕,那么接下来被唤醒的线程都无数据可处理

结论

只有在生产线程与消费线程都为多个的情况下才有可能发生虚假唤醒,只要有一方的数量为1,就不会发生!

3. 如何避免虚假唤醒

将消费者线程修改如下

void ConsumerFunction(unsigned threadIndex)

{

while(1)

{

unique_lock<mutex> locker(mutexForProduct);

while(queueForProduct.empty())

{

condVal.wait(locker);

}

if(queueForProduct.empty())

{

printf(“Consumer[%02u] Want To Buy Product, But There is not remain Product”, threadIndex);

assert(false);

}

unsigned productIndex = queueForProduct.front();

printf(“Consumer[%02u] Buying Product[%06u], RemainSize= %lu\n”, threadIndex, productIndex, queueForProduct.size());

queueForProduct.pop();

}

}

被唤醒后再次判断,若无数据可处理,则应继续休眠。

免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://itzsg.com/49284.html

(0)

相关推荐

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

联系我们YX

mu99908888

在线咨询: 微信交谈

邮件:itzsgw@126.com

工作时间:时刻准备着!

关注微信