在做多線程編程時(shí),有兩個(gè)場(chǎng)景我們都會(huì)遇到:
今天我用一個(gè)簡(jiǎn)單的例子來(lái)給大家介紹下鎖和條件變量的使用。
代碼使用C++11
示例代碼
#include <iostream>#include <mutex>#include <thread>#include <condition_variable>std::mutex g_mutex; // 用到的全局鎖std::condition_variable g_cond; // 用到的條件變量int g_i = 0;bool g_running = true;void ThreadFunc(int n) { // 線程執(zhí)行函數(shù) for (int i = 0; i < n; ++i) { { std::lock_guard<std::mutex> lock(g_mutex); // 加鎖,離開(kāi){}作用域后鎖釋放 ++g_i; std::cout << "plus g_i by func thread " << std::this_thread::get_id() << std::endl; } } std::unique_lock<std::mutex> lock(g_mutex); // 加鎖 while (g_running) { std::cout << "wait for exit" << std::endl; g_cond.wait(lock); // wait調(diào)用后,會(huì)先釋放鎖,之后進(jìn)入等待狀態(tài);當(dāng)其它進(jìn)程調(diào)用通知激活后,會(huì)再次加鎖 } std::cout << "func thread exit" << std::endl;}int main() { int n = 100; std::thread t1(ThreadFunc, n); // 創(chuàng)建t1線程(func thread),t1會(huì)執(zhí)行`ThreadFunc`中的指令 for (int i = 0; i < n; ++i) { { std::lock_guard<std::mutex> lock(g_mutex); ++g_i; std::cout << "plus g_i by main thread " << std::this_thread::get_id() << std::endl; } } { std::lock_guard<std::mutex> lock(g_mutex); g_running = false; g_cond.notify_one(); // 通知其它線程 } t1.join(); // 等待線程t1結(jié)束 std::cout << "g_i = " << g_i << std::endl;}程序運(yùn)行后,關(guān)鍵輸出如下:
plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744wait for exit // func thread等待main thread發(fā)來(lái)的退出信號(hào)plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816func thread exitg_i = 200 // 鎖機(jī)制保證了g_i的正確
可以看到:
std::this_thread::get_id()g_i
加鎖方法介紹
加鎖相關(guān)的代碼為:
{ std::lock_guard<std::mutex> lock(g_mutex); ......}要點(diǎn)為:
這樣就實(shí)現(xiàn)了加鎖和解鎖的過(guò)程,為什么不直接調(diào)用加鎖解鎖方法呢?
我想,這是因?yàn)槿绻渔i和解鎖中間的代碼出現(xiàn)了問(wèn)題,導(dǎo)致線程函數(shù)異常退出,那么這個(gè)鎖就一直無(wú)法得到釋放,其它線程處理的不好的話,就會(huì)造成死鎖了。
條件變量使用介紹
結(jié)束語(yǔ)
以上所述是小編給大家介紹的C++多線程中的鎖和條件變量使用教程,希望對(duì)大家有所幫助,如果大家有任何疑問(wèn)請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)VEVB武林網(wǎng)網(wǎng)站的支持!
新聞熱點(diǎn)
疑難解答