C++詳細講解互斥量與lock_guard類模板及死鎖
保護共享數(shù)據(jù),操作時,用代碼把共享數(shù)據(jù)鎖住、操作數(shù)據(jù)、解鎖
其他想操作共享數(shù)據(jù)的線程必須等待解鎖、鎖定住、操作、解鎖
互斥量的基本概念
- 互斥量是個類對象,理解成一把鎖,多個線程嘗試使用lock()成員函數(shù)來枷鎖這個鎖,是有一個線程可以鎖成功,成功的標志是返回
- 如果沒有鎖成功,那么流程卡在lock這里不斷嘗試去鎖
互斥量的使用
#include <iostream> #include <string> #include <thread> #include <vector> #include <list> #include <mutex> using namespace std; class A { public: //把收到的消息(玩家命令) 入到一個隊列的線程 void inMsgRecvQueue() { for (int i = 0; i < 1000; i++) { cout << "inMsgRecvQueue執(zhí)行,插入一個元素" << i << endl; my_mutex.lock(); msgRecvQueue.push_back(i);//假設這個數(shù)字就是收到的命令 my_mutex.unlock(); } } int mesg_lock_func(void) { int ret = 0; my_mutex.lock(); if (!msgRecvQueue.empty()) { ret = msgRecvQueue.front();//讀頭部元素 msgRecvQueue.pop_front();//移除頭部元素 //處理數(shù)據(jù) //cout << "接收到命令,處理命令" << ret << endl; } my_mutex.unlock(); return ret; } void outMsgRecvQueue() { int cmd = 0; for (int i = 0; i < 1000; i++) { cmd = mesg_lock_func(); if (cmd) { cout << "接收到命令,處理命令" << cmd << endl; } else { cout << "outMsgRecvQueue執(zhí)行,但目前消息隊列為空" << i << endl; } } } private: list<int> msgRecvQueue; //容器,專門用于代表玩家給咱們發(fā)送過來的命令 mutex my_mutex; };
lock_guard類模板
為什么此處只有一句 lock_guard sbguard(my_mutex);函數(shù)即可 不出問題
lock_guard原理:
lock_guard創(chuàng)建 sbguard(my_mutex);對象,會有構(gòu)造函數(shù),在構(gòu)造函數(shù)中進行了my_mutex.lock
在函數(shù)執(zhí)行結(jié)束后,局部對象會釋放,執(zhí)行析構(gòu)函數(shù)的時候會執(zhí)行my_mutex.unlock
int mesg_lock_func(void) { int ret = 0; //my_mutex.lock(); lock_guard<mutex> sbguard(my_mutex); if (!msgRecvQueue.empty()) { ret = msgRecvQueue.front();//讀頭部元素 msgRecvQueue.pop_front();//移除頭部元素 //處理數(shù)據(jù) //cout << "接收到命令,處理命令" << ret << endl; } //my_mutex.unlock(); return ret; }
死鎖
死鎖的條件:
兩個線程同時 鎖住 兩把鎖, A線程先鎖 鎖1,后鎖 鎖2;B線程先鎖 鎖2,后鎖 鎖1,就會發(fā)生死鎖
class A { public: //把收到的消息(玩家命令) 入到一個隊列的線程 void inMsgRecvQueue() { for (int i = 0; i < 10000; i++) { cout << "inMsgRecvQueue執(zhí)行,插入一個元素" << i << endl; my_mutex1.lock(); my_mutex2.lock(); msgRecvQueue.push_back(i);//假設這個數(shù)字就是收到的命令 my_mutex2.unlock(); my_mutex1.unlock(); } } int mesg_lock_func(void) { int ret = 0; my_mutex2.lock(); my_mutex1.lock(); //lock_guard<mutex> sbguard(my_mutex); if (!msgRecvQueue.empty()) { ret = msgRecvQueue.front();//讀頭部元素 msgRecvQueue.pop_front();//移除頭部元素 //處理數(shù)據(jù) //cout << "接收到命令,處理命令" << ret << endl; } my_mutex1.unlock(); my_mutex2.unlock(); return ret; } void outMsgRecvQueue() { int cmd = 0; for (int i = 0; i < 10000; i++) { cmd = mesg_lock_func(); if (cmd) { cout << "接收到命令,處理命令" << cmd << endl; } else { cout << "outMsgRecvQueue執(zhí)行,但目前消息隊列為空" << i << endl; } } } private: list<int> msgRecvQueue; //容器,專門用于代表玩家給咱們發(fā)送過來的命令 mutex my_mutex1; mutex my_mutex2; };
防止死鎖的條件:
兩個鎖的 鎖的順序必須相同
lock(mutex1, mutex2);
lock_guard sbguard1(my_mutex1,adopt_lock);’
lock與lock_guard的使用
int mesg_lock_func(void) { int ret = 0; lock(my_mutex1, my_mutex2); lock_guard<mutex> sbguard1(my_mutex1, adopt_lock); lock_guard<mutex> sbguard2(my_mutex2, adopt_lock); //lock_guard<mutex> sbguard(my_mutex); if (!msgRecvQueue.empty()) { ret = msgRecvQueue.front();//讀頭部元素 msgRecvQueue.pop_front();//移除頭部元素 //處理數(shù)據(jù) //cout << "接收到命令,處理命令" << ret << endl; } return ret; }
到此這篇關(guān)于C++詳細講解互斥量與lock_guard類模板及死鎖的文章就介紹到這了,更多相關(guān)C++互斥量內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
C++面向?qū)ο蠖嗉壊藛蜗駻rduino的移植問題小結(jié)
這篇文章主要介紹了C++面向?qū)ο蠖嗉壊藛蜗駻rduino的移植問題及實現(xiàn)思路,本文通過示例代碼給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧2024-06-06Qt連接數(shù)據(jù)庫并實現(xiàn)增刪改查操作
這篇文章主要為大家詳細介紹了Qt如何連接數(shù)據(jù)庫并實現(xiàn)增刪改查等基本操作,文中的示例代碼講解詳細,感興趣的小伙伴可以跟隨小編一起學習一下2023-09-09C++中strlen函數(shù)的三種實現(xiàn)方法
在C語言中我們要獲取字符串的長度,可以使用strlen?函數(shù),strlen?函數(shù)計算字符串的長度時,直到空結(jié)束字符,但不包括空結(jié)束字符,因為strlen函數(shù)時不包含最后的結(jié)束字符的,因此一般使用strlen函數(shù)計算的字符串的長度會比使用sizeof計算的字符串的字節(jié)數(shù)要小2022-05-05C語言動態(tài)內(nèi)存管理的原理及實現(xiàn)方法
C語言動態(tài)內(nèi)存管理的原理是通過 malloc() 函數(shù)申請一塊連續(xù)的內(nèi)存空間,并返回其地址,通過 free() 函數(shù)釋放該內(nèi)存空間。實現(xiàn)方法是通過在程序運行時動態(tài)地管理內(nèi)存,即在需要內(nèi)存時申請,不需要時釋放,避免了靜態(tài)內(nèi)存分配的浪費和不足2023-04-04