C++11用兩個線程輪流打印整數的實現方法
使用C++11標準的的線程語法,用兩個線程輪流打印整數,一個線程打印奇數,一個線程打印偶數??梢跃毩暰€程的基本操作、線程鎖和條件變量等技術。完整代碼如下。代碼后面附有主要語句的講解。
#include <thread>
#include <iostream>
#include <mutex>
#include <condition_variable>
std::mutex data_mutex;
std::condition_variable data_var;
bool label = false;
void printodd()
{
std::unique_lock<std::mutex> ulock(data_mutex) ;
for(int odd = 1; odd <= 100; odd += 2 )
{
data_var.wait(ulock,[]{return label;});
std::cout<< std::this_thread::get_id() << ": " << odd <<std::endl;
label = false;
data_var.notify_one();
}
}
void printeven()
{
std::unique_lock<std::mutex> ulock(data_mutex) ;
for(int even = 0; even < 100; even += 2 )
{
std::cout<< std::this_thread::get_id() << ": " << even <<std::endl;
data_var.notify_one();
label = true;
data_var.wait(ulock,[]{return !label;});
}
}
int main()
{
std::thread t1(printeven);
std::thread t2(printodd);
t1.join();
t2.join();
std::cout<<"end!"<<std::endl;
return 0;
}
程序中使用std::unique_lock<std::mutex> ulock(data_mutex)來管理互斥量,
這是一個RAII的資源管理方式,在ulock析構的時候,會自動釋放data_mutex。
std::condition_variable提供了兩種 wait() 函數。當前線程調用 wait() 后將被阻塞,此時當前線程應該獲得了鎖(也就是互斥量data_mutex),直到另外某個線程調用 notify_* 喚醒了當前線程。
在線程被阻塞時,該函數會自動調用 data_mutex.unlock() 釋放鎖,使得其他被阻塞在鎖競爭上的線程得以繼續(xù)執(zhí)行。另外,一旦當前線程獲得通知(notified,通常是另外某個線程調用 notify_* 喚醒了當前線程),wait()函數也是自動調用data_mutex.lock(),使得data_mutex的狀態(tài)和 wait 函數被調用時相同。
在第二種情況下(即設置了前提條件),只有當前提條件為false時調用 wait() 才會阻塞當前線程,并且在收到其他線程的通知后只有當前提條件為true 時才會被解除阻塞。
總結
到此這篇關于C++11用兩個線程輪流打印整數的實現方法的文章就介紹到這了,更多相關C++11線程打印整數內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
深入HRESULT與Windows Error Codes的區(qū)別詳解
本篇文章是對HRESULT與Windows Error Codes的區(qū)別進行了詳細的分析介紹,需要的朋友參考下2013-05-05

