在線程實際運行過程中,我們經(jīng)常需要多個線程保持同步。這時可以用互斥鎖來完成任務(wù);互斥鎖的使用過程中,主要有pthread_mutex_init,pthread_mutex_destory,pthread_mutex_lock,pthread_mutex_unlock這幾個函數(shù)以完成鎖的初始化,鎖的銷毀,上鎖和釋放鎖操作。 一,鎖的創(chuàng)建 鎖可以被動態(tài)或靜態(tài)創(chuàng)建,可以用宏P(guān)THREAD_MUTEX_INITIALIZER來靜態(tài)的初始化鎖,采用這種方式比較容易理解,互斥鎖是pthread_mutex_t的結(jié)構(gòu)體,而這個宏是一個結(jié)構(gòu)常量,如下可以完成靜態(tài)的初始化鎖: pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; 另外鎖可以用pthread_mutex_init函數(shù)動態(tài)的創(chuàng)建,函數(shù)原型如下: int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t * attr) 二,鎖的屬性 互斥鎖屬性可以由pthread_mutexattr_init(pthread_mutexattr_t *mattr);來初始化,然后可以調(diào)用其他的屬性設(shè)置方法來設(shè)置其屬性; 互斥鎖的范圍:可以指定是該進程與其他進程的同步還是同一進程內(nèi)不同的線程之間的同步??梢栽O(shè)置為PTHREAD_PROCESS_SHARE和PTHREAD_PROCESS_PRIVATE。默認是后者,表示進程內(nèi)使用鎖。可以使用int pthread_mutexattr_setpshared(pthread_mutexattr_t *mattr, int pshared) pthread_mutexattr_getshared(pthread_mutexattr_t *mattr,int *pshared) 用來設(shè)置與獲取鎖的范圍; 互斥鎖的類型:有以下幾個取值空間: PTHREAD_MUTEX_TIMED_NP,這是缺省值,也就是普通鎖。當一個線程加鎖以后,其余請求鎖的線程將形成一個等待隊列,并在解鎖后按優(yōu)先級獲得鎖。這種鎖策略保證了資源分配的公平性。 可以用 獲取或設(shè)置鎖的類型。 三,鎖的釋放 調(diào)用pthread_mutex_destory之后,可以釋放鎖占用的資源,但這有一個前提上鎖當前是沒有被鎖的狀態(tài)。 四,鎖操作 對鎖的操作主要包括加鎖 pthread_mutex_lock()、解鎖pthread_mutex_unlock()和測試加鎖 pthread_mutex_trylock()三個。 int pthread_mutex_lock(pthread_mutex_t *mutex) 五,鎖的使用
#include <pthread.h> #include <stdio.h> pthread_mutex_t mutex ; void *print_msg(void *arg){ int i=0; pthread_mutex_lock(&mutex); for(i=0;i<15;i++){ printf("output : %d\n",i); usleep(100); } pthread_mutex_unlock(&mutex); } int main(int argc,char** argv){ pthread_t id1; pthread_t id2; pthread_mutex_init(&mutex,NULL); pthread_create(&id1,NULL,print_msg,NULL); pthread_create(&id2,NULL,print_msg,NULL); pthread_join(id1,NULL); pthread_join(id2,NULL); pthread_mutex_destroy(&mutex); return 1; }將會一個線程一個線程的執(zhí)行。 |
|