您好,登錄后才能下訂單哦!
這篇文章主要介紹“C++互斥量、lock_guard類模板及死鎖實例分析”,在日常操作中,相信很多人在C++互斥量、lock_guard類模板及死鎖實例分析問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”C++互斥量、lock_guard類模板及死鎖實例分析”的疑惑有所幫助!接下來,請跟著小編一起來學習吧!
互斥量是個類對象,理解成一把鎖,多個線程嘗試使用lock()成員函數來枷鎖這個鎖,是有一個線程可以鎖成功,成功的標志是返回
如果沒有鎖成功,那么流程卡在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執行,插入一個元素" << i << endl; my_mutex.lock(); msgRecvQueue.push_back(i);//假設這個數字就是收到的命令 my_mutex.unlock(); } } int mesg_lock_func(void) { int ret = 0; my_mutex.lock(); if (!msgRecvQueue.empty()) { ret = msgRecvQueue.front();//讀頭部元素 msgRecvQueue.pop_front();//移除頭部元素 //處理數據 //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執行,但目前消息隊列為空" << i << endl; } } } private: list<int> msgRecvQueue; //容器,專門用于代表玩家給咱們發送過來的命令 mutex my_mutex; };
為什么此處只有一句 lock_guard sbguard(my_mutex);函數即可 不出問題
lock_guard原理:
lock_guard創建 sbguard(my_mutex);對象,會有構造函數,在構造函數中進行了my_mutex.lock
在函數執行結束后,局部對象會釋放,執行析構函數的時候會執行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();//移除頭部元素 //處理數據 //cout << "接收到命令,處理命令" << ret << endl; } //my_mutex.unlock(); return ret; }
死鎖的條件:
兩個線程同時 鎖住 兩把鎖, A線程先鎖 鎖1,后鎖 鎖2;B線程先鎖 鎖2,后鎖 鎖1,就會發生死鎖
class A { public: //把收到的消息(玩家命令) 入到一個隊列的線程 void inMsgRecvQueue() { for (int i = 0; i < 10000; i++) { cout << "inMsgRecvQueue執行,插入一個元素" << i << endl; my_mutex1.lock(); my_mutex2.lock(); msgRecvQueue.push_back(i);//假設這個數字就是收到的命令 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();//移除頭部元素 //處理數據 //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執行,但目前消息隊列為空" << i << endl; } } } private: list<int> msgRecvQueue; //容器,專門用于代表玩家給咱們發送過來的命令 mutex my_mutex1; mutex my_mutex2; };
防止死鎖的條件:
兩個鎖的 鎖的順序必須相同
lock(mutex1, mutex2);
lock_guard sbguard1(my_mutex1,adopt_lock);’
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();//移除頭部元素 //處理數據 //cout << "接收到命令,處理命令" << ret << endl; } return ret; }
到此,關于“C++互斥量、lock_guard類模板及死鎖實例分析”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續學習更多相關知識,請繼續關注億速云網站,小編會繼續努力為大家帶來更多實用的文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。