文章目錄

• • • • 線程同步機制
      • 互斥鎖
      • 互斥鎖使用示例

線程同步機制

---

線程同步機制引入 : 多個線程讀取同一個資源時 , 可能會造成沖突 , 因此需要引入線程同步機制 , 讓多個線程按照一定規則對共享的資源進行操作 ;

互斥鎖

---

互斥鎖使用流程 : ① 聲明互斥鎖 , ② 初始化互斥鎖 , ③ 加鎖 , ④ 解鎖 , ⑤ 銷毀互斥鎖 ;

• ① 聲明互斥鎖 ;

pthread_mutex_t mutex_t;

• ② 初始化互斥鎖 :

//初始化互斥鎖pthread_mutex_init(&mutex_t, 0);

• ③ 加鎖 :

//先用互斥鎖上鎖pthread_mutex_lock(&mutex_t);

• ④ 解鎖 :

//操作完畢后, 解鎖pthread_mutex_unlock(&mutex_t);

• ⑤ 銷毀互斥鎖 :

//銷毀互斥鎖pthread_mutex_destroy(&mutex_t);

互斥鎖使用示例

---

代碼示例 :

#include "005_Thread.h" #include <pthread.h>//引入隊列的頭文件 #include <queue>using namespace std;/*互斥鎖 :聲明 : 先聲明互斥鎖初始化 : 在進行初始化操作銷毀 : 使用完畢后 , 要將該互斥鎖銷毀 */ pthread_mutex_t mutex_t;//聲明一個隊列變量 // 該變量是全局變量 // 該變量要在不同的線程中訪問 , 用于展示線程同步 queue<int> que;/*操作線程方法 : 參數和返回值都是 void* 類型互斥鎖使用 : 多個線程對一個隊列進行操作 , 需要使用互斥鎖將該隊列鎖起來 , pthread_mutex_lock使用完畢后在進行解鎖 , pthread_mutex_unlock該類型的鎖與 Java 中的 synchronized 關鍵字一樣 , 屬于悲觀鎖其作用是通過 mutex 互斥鎖 , 將上鎖與解鎖之間的代碼進行同步 */ void* queue_thread_fun(void* args) {//先用互斥鎖上鎖pthread_mutex_lock(&mutex_t);if (!que.empty()) {//打印隊列中的第一個元素printf("獲取 queue_thread 隊列第一個數據 : %d\n", que.front());//將隊列首元素彈出que.pop();}else {printf("獲取 queue_thread 隊列為空\n");}//操作完畢后, 解鎖pthread_mutex_unlock(&mutex_t);return 0; }/*如果 8 個線程同時讀取隊列中的信息 , 會出現程序崩潰在多線程環境下 , 對隊列進 queue_thread 行操作 , queue_thread 是線程不安全的這里需要加鎖 , 進行 線程同步的操作 */ int main() {//初始化互斥鎖pthread_mutex_init(&mutex_t, 0);//向其中加入幾個int數據for (size_t i = 0; i < 5; i++) {que.push(i);}//創建多個線程操作 queue_thread 隊列pthread_t pids[8];for (size_t i = 0; i < 8; i++) {//創建線程pthread_create(&pids[i], 0, queue_thread_fun, 0);}//銷毀互斥鎖pthread_mutex_destroy(&mutex_t);return 0; }

執行結果 :

獲取 queue_thread 隊列第一個數據 : 0 獲取 queue_thread 隊列第一個數據 : 1 獲取 queue_thread 隊列第一個數據 : 2 獲取 queue_thread 隊列第一個數據 : 3 獲取 queue_thread 隊列第一個數據 : 4 獲取 queue_thread 隊列為空 獲取 queue_thread 隊列為空

總結

以上是生活随笔為你收集整理的【C++ 语言】pthread_mutex_t 互斥锁的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。