c++多線程為何要使用條件變量詳解
先看示例1：
#include <iostream>
#include <windows.h>
#include <mutex>
#include<deque>
#include <thread>
using namespace std;
int nmax = 20;
std::deque<int> m_que;
std::mutex mymutex;
//生產(chǎn)者
void producterex()
{
int i = 1;
while (i<nmax)
{
//休眠一秒鐘
std::this_thread::sleep_for(std::chrono::seconds(1));
std::unique_lock<mutex> lcx(mymutex);
m_que.push_back(i);
cout << "producted:" << i << endl;
lcx.unlock();
i++;
}
cout << "product thread exit\n";
}
//消費者
void consumerex()
{
int i = 0;
while (1)
{
std::unique_lock<mutex> lcx(mymutex);
if (!m_que.empty())
{
int i = m_que.back();
m_que.pop_back();
cout << "consumed:" << i << endl;
lcx.unlock();
i++;
if (i == nmax)
{
break;
}
}
else
{
lcx.unlock();
}
}
cout << "consumerex thread exit\n";
}
void main()
{
std::thread t1(producterex);
std::thread t2(consumerex);
t1.detach();
cout << "hello";
t2.detach();
cout << " world!\n";
getchar();
system("pause");
}
結(jié)果：
可見cpu使用率非常高。高的原因主要在消費者線程中，因為當(dāng)隊列為空的時候它也要執(zhí)行，做了過多的無用功導(dǎo)致CPU占有率過高，所以下面對進行一個改造讓其在空的時候等待200毫秒，相當(dāng)于增大了輪詢間隔周期，應(yīng)該能降低CPU的占用率。
在這里就貼上消費者的線程，因為其它的都一樣。
//消費者
void consumerex()
{
int i = 0;
while (1)
{
std::unique_lock<mutex> lcx(mymutex);
if (!m_que.empty())
{
int i = m_que.back();
m_que.pop_back();
cout << "consumed:" << i << endl;
lcx.unlock();
i++;
if (i == nmax)
{
break;
}
}
else
{
lcx.unlock();
std::this_thread::sleep_for(std::chrono::milliseconds(200));
}
}
cout << "consumerex thread exit\n";
}
結(jié)果：
可見CPU占用率一下子下降了。
這里就有一個困難了，那就是如何確定休眠的時間間隔（即輪詢間隔周期），如果間隔太短會過多占用CPU資源，如果間隔太長會因無法及時響應(yīng)造成延誤。
這就引入了條件變量來解決該問題：條件變量使用“通知—喚醒”模型，生產(chǎn)者生產(chǎn)出一個數(shù)據(jù)后通知消費者使用，消費者在未接到通知前處于休眠狀態(tài)節(jié)約CPU資源；當(dāng)消費者收到通知后，趕緊從休眠狀態(tài)被喚醒來處理數(shù)據(jù)，使用了事件驅(qū)動模型，在保證不誤事兒的情況下盡可能減少無用功降低對資源的消耗。
condition_variable介紹
在C++11中，我們可以使用條件變量（condition_variable）實現(xiàn)多個線程間的同步操作；當(dāng)條件不滿足時，相關(guān)線程被一直阻塞，直到某種條件出現(xiàn)，這些線程才會被喚醒。
成員函數(shù)如下：
條件變量是利用線程間共享的全局變量進行同步的一種機制，主要包括兩個動作：
a.一個線程因等待"條件變量的條件成立"而掛起；
b.另外一個線程使"條件成立"，給出信號，從而喚醒被等待的線程。
為了防止競爭，條件變量的使用總是和一個互斥鎖結(jié)合在一起；通常情況下這個鎖是std::mutex，并且管理這個鎖 只能是 std::unique_lockstd::mutex RAII模板類。
上面提到的兩個步驟，分別是使用以下兩個方法實現(xiàn)：
1.等待條件成立使用的是condition_variable類成員wait 、wait_for 或 wait_until。
2.給出信號使用的是condition_variable類成員notify_one或者notify_all函數(shù)。
以上兩個類型的wait函數(shù)都在會阻塞時，自動釋放鎖權(quán)限，即調(diào)用unique_lock的成員函數(shù)unlock（），以便其他線程能有機會獲得鎖。這就是條件變量只能和unique_lock一起使用的原因，否則當(dāng)前線程一直占有鎖，線程被阻塞。
虛假喚醒
在正常情況下，wait類型函數(shù)返回時要不是因為被喚醒，要不是因為超時才返回，但是在==實際中發(fā)現(xiàn)，因此操作系統(tǒng)的原因，wait類型在不滿足條件時，它也會返回，這就導(dǎo)致了虛假喚醒。==因此，我們一般都是使用帶有謂詞參數(shù)的wait函數(shù)，因為這種(xxx, Predicate pred )類型的函數(shù)等價于：
while (!pred()) //while循環(huán)，解決了虛假喚醒的問題
{
wait(lock);
}
原因說明如下：
假設(shè)系統(tǒng)不存在虛假喚醒的時，代碼形式如下：
if (不滿足xxx條件)
{
//沒有虛假喚醒，wait函數(shù)可以一直等待，直到被喚醒或者超時，沒有問題。
//但實際中卻存在虛假喚醒，導(dǎo)致假設(shè)不成立，wait不會繼續(xù)等待，跳出if語句，
//提前執(zhí)行其他代碼，流程異常
wait();
}
//其他代碼
...
正確的使用方式，使用while語句解決：
while (!(xxx條件) )
{
//虛假喚醒發(fā)生，由于while循環(huán)，再次檢查條件是否滿足，
//否則繼續(xù)等待，解決虛假喚醒
wait();
}
//其他代碼
....
下面看一個使用條件變量的情況：
#include <iostream>
#include <windows.h>
#include <mutex>
#include<deque>
#include <thread>
#include<condition_variable>
using namespace std;
int nmax = 10;
std::deque<int> m_que;
std::mutex mymutex;
condition_variable mycv;
//生產(chǎn)者
void producterex()
{
int i = 1;
while (i<nmax)
{
//休眠一秒鐘
std::this_thread::sleep_for(std::chrono::seconds(1));
std::unique_lock<mutex> lcx(mymutex);
m_que.push_back(i);
cout << "producted:" << i << endl;
lcx.unlock();
mycv.notify_one();
i++;
}
cout << "product thread exit\n";
}
//消費者
bool m_bflag = false;
void consumerex()
{
int i = 0;
bool m_bexit = false;
while (!m_bexit)
{
std::unique_lock<mutex> lcx(mymutex);
while (m_que.empty())
{
//避免虛假喚醒
mycv.wait(lcx);
if (m_bflag)
{
cout << "consumerex thread exit\n";
m_bexit = true;
break;
}
}
if (m_bexit)
{
break;
}
int i = m_que.back();
m_que.pop_back();
lcx.unlock();
cout << "consumed:" << i << endl;
}
cout << "consumerex thread exit\n";
}
void main()
{
std::thread t1(producterex);
std::thread t2(consumerex);
t1.detach();
cout << "hello";
t2.detach();
cout << " world!\n";
mycv.notify_one();
Sleep(15000);
m_que.push_back(100);
mycv.notify_one();
Sleep(3000);
m_bflag = true;
mycv.notify_one();//通知線程退出
getchar();
system("pause");
}
結(jié)果：
還可以將mycv.wait(lcx);換一種寫法，wait()的第二個參數(shù)可以傳入一個函數(shù)表示檢查條件，這里使用lambda函數(shù)最為簡單，如果這個函數(shù)返回的是true，wait()函數(shù)不會阻塞會直接返回，如果這個函數(shù)返回的是false，wait()函數(shù)就會阻塞著等待喚醒，如果被偽喚醒，會繼續(xù)判斷函數(shù)返回值。代碼示例如下：
#include <iostream>
#include <windows.h>
#include <mutex>
#include<deque>
#include <thread>
#include<condition_variable>
using namespace std;
int nmax = 10;
std::deque<int> m_que;
std::mutex mymutex;
condition_variable mycv;
//生產(chǎn)者
void producterex()
{
int i = 1;
while (i<nmax)
{
//休眠一秒鐘
std::this_thread::sleep_for(std::chrono::seconds(1));
std::unique_lock<mutex> lcx(mymutex);
m_que.push_back(i);
cout << "producted:" << i << endl;
lcx.unlock();
mycv.notify_one();
i++;
}
cout << "product thread exit\n";
}
//消費者
bool m_bflag = false;
void consumerex()
{
int i = 0;
while (1)
{
std::unique_lock<mutex> lcx(mymutex);
mycv.wait(lcx, [](){
//返回false就繼續(xù)等待
return !m_que.empty();
});
if (m_bflag)
{
break;
}
int i = m_que.back();
m_que.pop_back();
lcx.unlock();
cout << "consumed:" << i << endl;
}
cout << "consumerex thread exit\n";
}
void main()
{
std::thread t1(producterex);
std::thread t2(consumerex);
t1.detach();
cout << "hello";
t2.detach();
cout << " world!\n";
mycv.notify_one();
Sleep(15000);
m_que.push_back(100);
mycv.notify_one();
Sleep(3000);
m_bflag = true;
m_que.push_back(-1);
mycv.notify_one();//通知線程退出
getchar();
system("pause");
}
總結(jié)
到此這篇關(guān)于c++多線程為何要使用條件變量的文章就介紹到這了,更多相關(guān)c++多線程條件變量內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要為大家詳細介紹了C語言實現(xiàn)簡單猜拳小游戲，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-03-03
今天小編就為大家分享一篇減少OpenCV讀取高分辨率圖像的時間示例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2019-12-12
這篇文章主要介紹了C++枚舉類型用法總結(jié)(枚舉字符常量代替常量),文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-12-12
sizeof操作符以字節(jié)形式給出了其操作數(shù)的存儲大小2013-04-04
本文給大家分享的是一個使用c++繪制心形的代碼，雖然情人節(jié)已經(jīng)過去了，但是只要有心，天天都是情人節(jié)~~哈哈，讓那些說程序猿都是木頭的人去死吧。2015-03-03
boost.asio框架系列之調(diào)度器io_service
這篇文章介紹了boost.asio框架系列之調(diào)度器io_service，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06
這篇文章主要為大家介紹了switch語句，switch語句是我們常見會用到的結(jié)構(gòu)，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-06-06
C/C++中g(shù)etline函數(shù)案例總結(jié)
這篇文章主要介紹了C/C++中g(shù)etline函數(shù)案例總結(jié),本篇文章通過簡要的案例,講解了該項技術(shù)的了解與使用,以下就是詳細內(nèi)容,需要的朋友可以參考下2021-09-09
這篇文章主要介紹了C++ tuple元組的基本用法(總結(jié))，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-07-07
這篇文章主要介紹了C語言實現(xiàn)三子棋的步驟和代碼詳解,本文通過實例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12