Linux系統編程 —互斥量mutex


互斥量mutex

前文提到,系統中如果存在資源共享,線程間存在競爭,並且沒有合理的同步機制的話,會出現數據混亂的現象。為了實現同步機制,Linux中提供了多種方式,其中一種方式為互斥鎖mutex(也稱之為互斥量)。

互斥量的具體實現方式為:每個線程在對共享資源操作前都嘗試先加鎖,成功加鎖后才可以對共享資源進行讀寫操作,操作結束后解鎖。

互斥量不是為了消除競爭,實際上,資源還是共享的,線程間也還是競爭的,只不過通過這種“鎖”機制就將共享資源的訪問變成互斥操作,也就是說一個線程操作這個資源時,其它線程無法操作它,從而消除與時間有關的錯誤。

從互斥量的實現機制我們可以看出,同一時刻,只能有一個線程持有該鎖。如果有同時有多個線程持有該鎖,那就沒有實際意義了。

但是,這種鎖機制不是強制的,互斥鎖實質上是操作系統提供的一把“建議鎖”(又稱“協同鎖”),建議程序中有多線程訪問共享資源的時候使用該機制。

因此,即使有了mutex,其它線程如果不按照這種鎖機制來訪問共享數據的話,依然會造成數據混亂。所以為了避免這種情況,所有訪問該共享資源的線程必須采用相同的鎖機制。

主要應用函數:

​ pthread_mutex_init函數
​ pthread_mutex_destroy函數
​ pthread_mutex_lock函數
​ pthread_mutex_trylock函數
​ pthread_mutex_unlock函數

以上5個函數的返回值都是:成功返回0,失敗返回錯誤號。

在Linux環境下,類型pthread_mutex_t其本質是一個結構體。但是為了簡化理解,應用時可忽略其實現細節,簡單當成整數看待。mutex一般以下面方式定義:

pthread_mutex_t mutex;

變量mutex只有兩種取值1、0。

pthread_mutex_init函數

函數原型:

int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);

函數作用:

初始化一個互斥鎖(互斥量)mutex,初值可視為1;

參數介紹:

mutex:傳出參數,調用時應傳 &mutex給該函數;

這里有個關鍵字比較特殊:restrict。它的作用只用於限制指針,告訴編譯器,所有修改該指針指向內存中內容的操作,只能通過本指針完成。不能通過除本指針以外的其他變量或指針修改。比如說,再定義個pthread_mutex_t的指針,將其賦值為mutex的值,想要用它來修改mutex所指向的內存,這是不允許的。

attr:互斥量屬性。是一個傳入參數,通常傳NULL,表示使用默認屬性(即:線程間共享)。

對於互斥量mutex的初始化有兩種方式:

1. 靜態初始化:

如果互斥鎖 mutex 是靜態分配的,即:定義為全局變量,或加了static關鍵字修飾,可以直接使用宏進行初始化。e.g. pthead_mutex_t muetx = PTHREAD_MUTEX_INITIALIZER;

2. 動態初始化:

如果互斥鎖mutex定義為局部變量,則應采用動態初始化。e.g. pthread_mutex_init(&mutex, NULL)

pthread_mutex_destroy函數

函數原型:

int pthread_mutex_destroy(pthread_mutex_t *mutex);

函數作用:

銷毀一個互斥鎖

pthread_mutex_lock函數

函數原型:

int pthread_mutex_lock(pthread_mutex_t *mutex);

函數作用:

對共享資源進行加鎖。可理解為將mutex--(或-1);如果加鎖不成功,則該線程將阻塞,直到持有該互斥量的其他線程解鎖為止。注意:在訪問共享資源前加鎖,訪問結束后立即解鎖。鎖的“粒度”應越小越好。

pthread_mutex_unlock函數

函數原型:

int pthread_mutex_unlock(pthread_mutex_t *mutex);

函數作用:

對共享資源解鎖。可理解為將mutex ++(或+1);在解鎖的同時,會將阻塞在該鎖上的所有線程全部喚醒,至於哪個線程先被喚醒,取決於優先級、調度。默認情況下:先阻塞的線程會先被喚醒。

pthread_mutex_trylock函數

函數原型:

int pthread_mutex_trylock(pthread_mutex_t *mutex);

函數作用:

對共享資源嘗試加鎖。它與pthread_mutex_lock函數的區別是,使用lock函數對共享資源進行加鎖時,如果加鎖不成功,則線程就阻塞;而如果使用trylock,則加鎖不成功時不會阻塞當前線程,而是立即返回一個值來描述互斥鎖的狀況。

死鎖:

  1. 線程試圖對同一個互斥量A加鎖兩次。
  2. 線程1擁有A鎖,請求獲得B鎖;線程2擁有B鎖,請求獲得A鎖
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <pthread.h>

pthread_mutex_t mutex;

void *tfn(void *arg)
{
    srand(time(NULL));

    while(1) {
        pthread_mutex_lock(&mutex);
        printf("hello ");           // 標准輸出為共享資源
        sleep(rand() % 3);          // 在此時會失去CPU
        printf("world!\n");
        pthread_mutex_unlock(&mutex);
        sleep(rand() % 3);
    }
    return NULL;
}

int main()
{
    pthread_t tid;
    int n = 5;

    srand(time(NULL));

    pthread_mutex_init(&mutex, NULL);
    pthread_create(&tid, NULL, tfn, NULL);

    while(n--) {
        pthread_mutex_lock(&mutex);
        printf("HELLO ");
        sleep(rand() % 3);
        printf("WORLD!\n");
        pthread_mutex_unlock(&mutex);
        sleep(rand() % 3);
    }

    pthread_cancel(tid);
    pthread_join(tid, NULL);

    pthread_mutex_destroy(&mutex);
    return 0;
}

更多精彩內容,請關注公眾號良許Linux,公眾內回復1024可免費獲得5T技術資料,包括:Linux,C/C++,Python,樹莓派,嵌入式,Java,人工智能,等等。公眾號內回復進群,邀請您進高手如雲技術交流群。

img


公眾號:良許Linux

有收獲?希望老鐵們來個三連擊,給更多的人看到這篇文章


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM