1. 程式人生 > >訊號量、互斥鎖、讀寫鎖和條件變數之間的區別

訊號量、互斥鎖、讀寫鎖和條件變數之間的區別

訊號量 強調的是執行緒(或程序)間的同步:“訊號量用在多執行緒多工同步的,一個執行緒完成了某一個動作就通過訊號量告訴別的執行緒,別的執行緒再進行某些動作(大家都在sem_wait的時候,就阻塞在那裡)。當訊號量為單值訊號量是,也可以完成一個資源的互斥訪問。

有名訊號量:可以用於不同程序間或多執行緒間的互斥與同步

建立開啟有名訊號量

sem_t *sem_open(const char *name, int oflag);

sem_t *sem_open(const char *name, int oflag, mode_t mode, unsigned int value); 成功返回訊號量指標;失敗返回SEM_FAILED,設定errno name是檔案路徑名,但不能寫成/tmp/a.sem這樣的形式,因為在linux下,sem都是在/dev/shm目錄下,可寫成"/mysem"或"mysem",創建出來的檔案都是"/dev/shm/sem.mysem",mode設定為0666,value設定為訊號量的初始值.所需訊號燈等已存在條件下指定 O_CREAT|O_EXCL卻是個錯誤。

關閉訊號量,程序終止時,會自動呼叫它

int sem_close(sem_t *sem);

成功返回0;失敗返回-1,設定errno

刪除訊號量,立即刪除訊號量名字,當其他程序都關閉它時,銷燬它

int sem_unlink(const char *name);

等待訊號量,測試訊號量的值,如果其值小於或等於0,那麼就等待(阻塞);一旦其值變為大於0就將它減1,並返回

int sem_wait(sem_t *sem);

int sem_trywait(sem_t *sem);

成功返回0;失敗返回-1,設定errno

當訊號量的值為0時,sem_trywait立即返回,設定errno為EAGAIN。如果被某個訊號中斷,sem_wait會過早地返回,設定errno為EINTR

發出訊號量,給它的值加1,然後喚醒正在等待該訊號量的程序或執行緒

int sem_post(sem_t *sem);

成功返回0;失敗返回-1,不會改變它的值,設定errno,該函式是非同步訊號安全的,可以在訊號處理程式裡呼叫它

無名訊號量,用於程序體內各執行緒間的互斥和同步,使用如下API(無名訊號量,基於記憶體的訊號量)

(1)、sem_init 功能:用於建立一個訊號量,並初始化訊號量的值。

函式原型: int sem_init (sem_t* sem, int pshared, unsigned int value);

函式傳入值: sem:訊號量。pshared:決定訊號量能否在幾個程序間共享。由於目前LINUX還沒有實現程序間共享資訊量,所以這個值只能取0。

(2)其他函式。

int sem_wait (sem_t* sem);

int sem_trywait (sem_t* sem);

int sem_post (sem_t* sem);

int sem_getvalue (sem_t* sem);

int sem_destroy (sem_t* sem);

功能:sem_wait和sem_trywait相當於P操作,它們都能將訊號量的值減一,兩者的區別在於若訊號量的值小於零時,sem_wait將會阻塞程序,而sem_trywait則會立即返回。sem_post相當於V操作,它將訊號量的值加一,同時發出喚醒的訊號給等待 的程序(或執行緒)。

sem_getvalue 得到訊號量的值。

sem_destroy 摧毀訊號量。

如果某個基於記憶體的訊號燈是在不同程序間同步的,該訊號燈必須存放在共享記憶體區中,這要只要該共享記憶體區存在,該訊號燈就存在。

互斥鎖(又名互斥量)

強調的是資源的訪問互斥:互斥鎖是用在多執行緒多工互斥的,一個執行緒佔用了某一個資源,那麼別的執行緒就無法訪問,直到這個執行緒unlock,其他的執行緒才開始可以利用這個資源。比如對全域性變數的訪問,有時要加鎖,操作完了,在解鎖。有的時候鎖和訊號量會同時使用的” 也就是說,訊號量不一定是鎖定某一個資源,而是流程上的概念,比如:有A,B兩個執行緒,B執行緒要等A線完成某一任務以後再進行自己下面的步驟,這個任務並不一定是鎖定某一資源,還可以是進行一些計算或者資料處理之類。而執行緒互斥量則是“鎖住某一資源”的概念,在鎖定期間內,程無法對被保護的資料進行操作。在有些情況下兩者可以互換。

在linux下, 執行緒的互斥量資料型別是pthread_mutex_t. 在使用前, 要對它進行初始化:

對於靜態分配的互斥量, 可以把它設定為PTHREAD_MUTEX_INITIALIZER, 或者呼叫pthread_mutex_init.

對於動態分配的互斥量, 在申請記憶體(malloc)之後, 通過pthread_mutex_init進行初始化, 並且在釋放記憶體(free)前需要呼叫pthread_mutex_destroy.

原型:
    int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restric attr);
   
    int pthread_mutex_destroy(pthread_mutex_t *mutex);

返回值: 成功則返回0, 出錯則返回錯誤編號.

說明: 如果使用預設的屬性初始化互斥量, 只需把attr設為NULL. 其他值在以後講解.

 首先說一下加鎖函式:

    int pthread_mutex_lock(pthread_mutex_t *mutex);

    int pthread_mutex_trylock(pthread_mutex_t *mutex);

返回值: 成功則返回0, 出錯則返回錯誤編號.

說 明: 具體說一下trylock函式, 這個函式是非阻塞呼叫模式, 也就是說, 如果互斥量沒被鎖住, trylock函式將把互斥量加鎖, 並獲得對共享資源的訪問許可權; 如果互斥量被鎖住了, trylock函式將不會阻塞等待而直接返回EBUSY, 表示共享資源處於忙狀態.

 再說一下解所函式:

原型: int pthread_mutex_unlock(pthread_mutex_t *mutex);

返回值: 成功則返回0, 出錯則返回錯誤編號.

條件變數常與互斥鎖同時使用,達到執行緒同步的目的:條件變數通過允許執行緒阻塞和等待另一個執行緒傳送訊號的方法彌補了互斥鎖的不足。在發 送訊號時,如果沒有執行緒等待在該條件變數上,那麼訊號將丟失;而訊號量有計數值,每次訊號量post操作都會被記錄

  1. 互斥鎖必須是誰上鎖就由誰來解鎖,而訊號量的wait和post操作不必由同一個執行緒執行。

  2. 互斥鎖要麼被鎖住,要麼被解開,和二值訊號量類似

  3. sem_post是各種同步技巧中,唯一一個能在訊號處理程式中安全呼叫的函式

  4. 互斥鎖是為上鎖而優化的;條件變數是為等待而優化的; 訊號量既可用於上鎖,也可用於等待,因此會有更多的開銷和更高的複雜性 待,因此會有更多的開銷和更高的複雜性

  5. 互斥鎖,條件變數都只用於同一個程序的各執行緒間,而訊號量(有名訊號量)可用於不同程序間的同步。當訊號量用於程序間同步時,要求訊號量建立在共享記憶體區。

  6. 訊號量有計數值,每次訊號量post操作都會被記錄,而條件變數在傳送訊號時,如果沒有執行緒在等待該條件變數,那麼訊號將丟失。

讀寫鎖

讀寫鎖與互斥量類似,不過讀寫鎖允許更高的並行性。互斥量要麼是鎖住狀態要麼是不加鎖狀態,而且一次只有一個執行緒可以對其加鎖。

讀寫鎖可以由三種狀態:讀模式下加鎖狀態、寫模式下加鎖狀態、不加鎖狀態。一次只有一個執行緒可以佔有寫模式的讀寫鎖,但是多個執行緒可以同時佔有讀模式的讀寫鎖。

在讀寫鎖是寫加鎖狀態時,在這個鎖被解鎖之前,所有試圖對這個鎖加鎖的執行緒都會被阻塞。當讀寫鎖在讀加鎖狀態時,所有試圖以讀模式對它進行加鎖的執行緒都可以得到訪問權,但是如果執行緒希望以寫模式對此鎖進行加鎖,它必須阻塞直到所有的執行緒釋放讀鎖。雖然讀寫鎖的實現各不相同,但當讀寫鎖處於讀模式鎖住狀態時,如果有另外的執行緒試圖以寫模式加鎖,讀寫鎖通常會阻塞隨後的讀模式鎖請求。這樣可以避免讀模式鎖長期佔用,而等待的寫模式鎖請求一直得不到滿足。

讀寫鎖非常適合於對資料結構讀的次數遠大於寫的情況。當讀寫鎖在寫模式下時,它所保護的資料結構就可以被安全地修改,因為當前只有一個執行緒可以在寫模式下擁有這個鎖。當讀寫鎖在讀狀態下時,只要執行緒獲取了讀模式下的讀寫鎖,該鎖所保護的資料結構可以被多個獲得讀模式鎖的執行緒讀取。

讀寫鎖也叫做共享-獨佔鎖,當讀寫鎖以讀模式鎖住時,它是以共享模式鎖住的;當他以寫模式鎖住時,它是以獨佔模式鎖住的。

初始化和銷燬:

int pthread_rwlock_init(pthread_rwlock_t *restrict rwlock, const pthread_rwlockattr_t *restrict attr);

int pthread_rwlock_destroy(pthread_rwlock_t *rwlock);

成功則返回0, 出錯則返回錯誤編號.

同互斥量以上, 在釋放讀寫鎖佔用的記憶體之前, 需要先通過pthread_rwlock_destroy對讀寫鎖進行清理工作, 釋放由init分配的資源.

讀和寫:

int pthread_rwlock_rdlock(pthread_rwlock_t *rwlock);

int pthread_rwlock_wrlock(pthread_rwlock_t *rwlock);

int pthread_rwlock_unlock(pthread_rwlock_t *rwlock);

成功則返回0, 出錯則返回錯誤編號. 這3個函式分別實現獲取讀鎖, 獲取寫鎖和釋放鎖的操作. 獲取鎖的兩個函式是阻塞操作,

同樣, 非阻塞的函式為:

int pthread_rwlock_tryrdlock(pthread_rwlock_t *rwlock);

int pthread_rwlock_trywrlock(pthread_rwlock_t *rwlock);

成功則返回0, 出錯則返回錯誤編號.

非阻塞的獲取鎖操作, 如果可以獲取則返回0, 否則返回錯誤的EBUSY.

雖然讀寫鎖提高了並行性,但是就速度而言並不比互斥量快. 可能這也是即使有讀寫鎖存在還會使用互斥量的原因,因為他在速度方面略勝一籌。這就需要我們在寫程式的時候 綜合考慮速度和並行性並找到一個折中。

比如: 假設使用互斥量需要0.5秒,使用讀寫鎖需要0.8秒。在類似學生管理系統這類軟體中,可能百分之九十的 時間都是查詢操作,那麼假如現在突然來個個20個請求,如果使用的是互斥量,那麼最後的那個查詢請求被滿足需要10後。這樣,估計沒人能受得了。而使用讀寫鎖,應為讀鎖能夠多次獲得。所以所有的20個請求,每個請求都能在1秒左右 得到滿足。

也就是說,在一些寫操作比較多或是本身需要同步的地方並不多的程式中我們應該使用互斥量,而在讀操作遠大於寫操作的一些程式中我們應該使用讀寫鎖來進行同步

條件變數(condition)

條件變數與互斥量一起使用時,允許執行緒以無競爭的方式等待特定的條件發生。

條件本身是由互斥量保護的。執行緒在改變條件狀態前必須首先鎖住互斥量,其它執行緒在獲得互斥量之前不會察覺到這種改變,因此必須鎖定互斥量以後才能計算條件。

條件的檢測是在互斥鎖的保護下進行的。如果一個條件為假,一個執行緒自動阻塞,並釋放等待狀態改變的互斥鎖。如果另一個執行緒改變了條件,它發訊號給關聯的條件變數,喚醒一個或多個等待它的執行緒,重新獲得互斥鎖,重新評價條件。如果兩程序共享可讀寫的記憶體,條件變數可以被用來實現這兩程序間的執行緒同步。

  1. 初始化:

條件變數採用的資料型別是pthread_cond_t, 在使用之前必須要進行初始化, 這包括兩種方式:

靜態: 可以把常量PTHREAD_COND_INITIALIZER給靜態分配的條件變數.

動態: pthread_cond_init函式, 是釋放動態條件變數的記憶體空間之前, 要用pthread_cond_destroy對其進行清理.

int pthread_cond_init(pthread_cond_t *restrict cond, pthread_condattr_t *restrict attr);

int pthread_cond_destroy(pthread_cond_t *cond);

成功則返回0, 出錯則返回錯誤編號.

注意:條件變數佔用的空間並未被釋放。

當pthread_cond_init的attr引數為NULL時, 會建立一個預設屬性的條件變數; 非預設情況以後討論.

  1. 等待條件:

int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restric mutex);

int pthread_cond_timedwait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex, const struct timespec *restrict timeout);

成功則返回0, 出錯則返回錯誤編號.

這兩個函式分別是阻塞等待和超時等待.

等待條件函式等待條件變為真, 傳遞給pthread_cond_wait的互斥量對條件進行保護, 呼叫者把鎖住的互斥量傳遞給函式. 函式把呼叫執行緒放到等待條件的執行緒列表上, 然後對互斥量解鎖, 這兩個操作是原子的. 這樣 便關閉了條件檢查和執行緒進入休眠狀態等待條件改變這兩個操作之間的時間通道, 這樣執行緒就不會錯過條件的任何變化.

當pthread_cond_wait返回時, 互斥量再次被鎖住.

pthread_cond_wait函式的返回並不意味著條件的值一定發生了變化,必須重新檢查條件的值。

pthread_cond_wait函式返回時,相應的互斥鎖將被當前執行緒鎖定,即使是函數出錯返回。

阻塞在條件變數上的執行緒被喚醒以後,直到pthread_cond_wait()函式返回之前條件的值都有可能發生變化。所以函式返回以後,在鎖定相應的互斥鎖之前,必須重新測試條件值。最好的測試方法是迴圈呼叫pthread_cond_wait函式,並把滿足條件的表示式置為迴圈的終止條件。如:

pthread_mutex_lock();

while (condition_is_false)

pthread_cond_wait();

pthread_mutex_unlock();

阻塞在同一個條件變數上的不同執行緒被釋放的次序是不一定的。 注意:pthread_cond_wait()函式是退出點,如果在呼叫這個函式時,已有一個掛起的退出請求,且執行緒允許退出,這個執行緒將被終止並開始執行善後處理函式,而這時和條件變數相關的互斥鎖仍將處在鎖定狀態。

pthread_cond_timedwait函式到了一定的時間,即使條件未發生也會解除阻塞。這個時間由引數abstime指定。函式返回時,相應的互斥鎖往往是鎖定的,即使是函數出錯返回。

注意:pthread_cond_timedwait函式也是退出點。

超時時間引數是指一天中的某個時刻。使用舉例:

pthread_timestruc_t to;

to.tv_sec = time(NULL) + TIMEOUT;

to.tv_nsec = 0;

超時返回的錯誤碼是ETIMEDOUT。

  1. 通知條件:

    int pthread_cond_signal(pthread_cond_t *cond);

    int pthread_cond_broadcast(pthread_cond_t *cond);

成功則返回0, 出錯則返回錯誤編號.

這兩個函式用於通知執行緒條件已經滿足. 呼叫這兩個函式, 也稱向執行緒或條件傳送訊號. 必須注意, 一定要在改變條件狀態以後再給執行緒傳送訊號.