原文來自:http://chenlq.net/vc11-bit-sweet-condition-variable-condition_variable-header-files.html
天啊,cppblog的編輯器能不能再爛一點?
有興趣的同學,去看原文吧,無語了 :(
條件變量,是C++11中為了簡化線程之間訪問某個共享資源而提出的。在這個應用場景中,這個共享資源往往表現為某種條件。例如在生產者-消費者模式中,我們往往需要判斷用于存放產品的容器是在什么狀態(條件)下。如果容器是空的,生產者線程可以繼續,而消費者線程則需要暫停,而如果容器已經滿了,生產者線程需要暫停,而消費者線程可以繼續。而在這個場景中,我們就可以用條件變量來協調兩個線程之間的動作。關于條件變量在生產者-消費者模式下的應用,我給出了一個例子。
條件變量在協調兩個線程之間的協作的時候非常有用,我們這里再補充一個例子。假設我們需要為政府設計一個程序來管理路燈。在這里,我們用一個線程來檢查是否到了觀燈的時間,而另外一個線程則負責在條件滿足后關閉路燈。
#include
#include // 時間工具
#include // 線程
#include // 條件變量
#include // 互斥
using namespace std;
using namespace std::chrono;
// 條件變量
condition_variable cond;
// 互斥
mutex m;
// 表示條件的共享資源
bool morning = false;
// 檢查是否到了關燈的時間
void check()
{
// 記錄開始時間
auto start = system_clock::now();
do
{
// 當前線程休眠1000毫秒
this_thread::sleep_for(milliseconds(1000));
cout<<"it is still night."<<endl;
} // 檢查是否已經到了關燈的時刻
// 這里用seconds(4)表示路燈持續4秒
while ( system_clock::now() < start + seconds(4));
// 到達關燈時間,鎖定互斥對象,
// 修改表示條件的共享數據morning
lock_guard lk(m);
cout<<"it is morning."<<endl;
morning = true;
// 用notify_one()通知另外的線程,條件已經發送變化
cond.notify_one();
}
/// 關燈線程
void turnoff()
{
// 鎖定互斥對象,訪問表示條件的共享資源morning
unique_lock lk(m);
// 構造一個循環,只要條件沒有滿足
// 就一直執行條件變量的wait()方法,讓當前線程等待
while(!morning)
{
cond.wait(lk);
}
// 條件滿足。執行關燈動作
cout<<"turn off the light."<<endl;
}
int main(int argc, char* argv[])
{
// 創建兩個線程,分別執行檢查和關燈的動作
thread c(check);
thread t(turnoff);
c.join();
t.join();
return 0;
}
從這個例子中,我們可以得到這樣一些使用條件變量的要點:
條件變量總是需要與一個表示條件的共享資源以及對這個共享資源進行訪問控制的互斥對象。這就是我們在程序的開始部分定義的morning,m和cond。
// 條件變量
condition_variable cond;
// 互斥
mutex m;
// 表示條件的共享資源
bool morning = false;
這三者幾乎總是相伴同時出現。
在一個線程中,我們需要在條件滿足的時候修改表示條件的共享資源的值,然后用條件變量的notify_one()或者notify_all()通知正在等待的線程。這就是
// 到達關燈時間,鎖定互斥對象,
// 修改表示條件的共享數據morning
lock_guard lk(m);
cout<<"it is morning."<<endl;
morning = true;
// 用notify_one()通知另外的線程,條件已經發送變化
cond.notify_one();
而在另外一個線程中,我們需要構造一個以共享資源為條件的無限循環,當條件無法滿足時,就用條件變量的wait()或者wait_until()等函數進行等待,直到條件得到滿足,循環結束。
// 鎖定互斥對象,訪問表示條件的共享資源morning
unique_lock lk(m);
// 構造一個循環,只要條件沒有滿足
// 就一直執行條件變量的wait()方法,讓當前線程等待
while(!morning)
{
cond.wait(lk);
}
總結起來,條件變量簡化了對表示條件的共享資源的訪問,也省去了對共享資源的頻繁的鎖操作,進一步提高了效率。