互斥：

簡(jiǎn)單的理解就是一個(gè)縣城進(jìn)入工作區(qū)之后，如果有其他的線程想要進(jìn)入工作區(qū)，他就會(huì)進(jìn)入等待狀態(tài)，要等待工作區(qū)內(nèi)的線程結(jié)束后才可以進(jìn)入。

基本函數(shù)：

（1）pthread_mutex_init()函數(shù)

原型： int pthread_mutex_init（phread_mutex_t *mutex,const pthread_mutexattr_t * attr）;

描述：設(shè)置互斥性的屬性

參數(shù)：第一個(gè)參數(shù)：預(yù)先聲明的pthread_mutex_t 對(duì)象指針

????????? ?第二個(gè)參數(shù)：互斥鎖屬性，null 表示使用默認(rèn)屬性

返回值：成功時(shí)返回0，失敗時(shí)1返回一個(gè)錯(cuò)誤代碼

（2）pthread_mutex_lock()

原型： int pthread_mutex_lock(pthread_mutex_t * mutex);

描述：pthread_mutex_lock返回時(shí)，互斥鎖被鎖定，如果這個(gè)互斥鎖被一個(gè)線程鎖定和擁有，那么另一個(gè)線程要調(diào)用這個(gè)函數(shù)會(huì)進(jìn)入擁塞狀態(tài)（即等待狀態(tài)），直到互斥鎖被釋放為止。

返回值：成功時(shí)，返回0 ，失敗時(shí) 返回錯(cuò)誤代碼

（3）pthread_mutex_unlock()函數(shù)

原型：int pthread_mutex_unlock(pthread_mutex_t *mutex);

描述：釋放互斥鎖

返回值：成功時(shí)返回0，失敗時(shí)返回一個(gè)錯(cuò)誤代碼

（4）pthread_mutex_destroy()函數(shù)

原型：int pthread_mutex_destroy(pthread_mutex_t * mutex);

描述：刪除互斥鎖

返回值：成功時(shí)返回0 ，失敗時(shí)返回錯(cuò)誤代碼

?

實(shí)例：

lock.c文件

描述：這個(gè)程序主要可以概括為主線程負(fù)責(zé)接受輸入的字符串，而子線程負(fù)責(zé)統(tǒng)計(jì)并輸出字符數(shù)。

#include<stdio.h>

#include<unistd.h>

#include<stdlib.h>

#include<pthread.h>

#include<semaohore.h>

?

void *thread_function(void * arg);

pthread_mutex_t work_mutex;//創(chuàng)建一個(gè)線程變量

#define work_size 1024

char work_area[work_size];

int time_to_exit = 0;

int main()

{

int res;

pthread_t a_thread;

void * thread_result;

//初始化互斥量

res = pthread_mutex_init(&work_mutex,NULL);

?

if(res != 0)

{

printf("互斥量初始化失敗\n");

exit(EXIT_FAILURE);

}

?

//啟動(dòng)新的線程

res = pthread_create(&a_thread,????NULL, thread_function ,NULL);

if(res !=0 )

{

perror("線程創(chuàng)建失敗\n");

exit(1);

}

?

pthread_mutex_lock(&work_mutex);

printf("請(qǐng)輸入一些文本，輸入end 結(jié)束：\n");

while(! time_to_exit)

{

fgets(work_area,work_size,stdin);

pthread_mutex_unlock(&work_mutex);

while(1)

{

pthread_mutex_lock(&work_mutex);

if(work_area[0]!= '\0')

{

pthread_mutex_unlock(&work_mutex);

sleep(1)

}

else

{

break;

}

}

}

pthread_mutex_unlock(&work_mutex);
printf("等待線程結(jié)束：...\n");

res = pthread_join(a_thread,&thread_result);

if(res != 0?)

{

perror("thread join failed\n");

exit(1);

}

printf("thread oined\n");

pthread_mutex_destroy(&work_mutex);

exit(1);

}

//主線程首先鎖定工作區(qū)，在獲取輸入的字符串后，釋放工作區(qū)，讓其它線程對(duì)字符個(gè)數(shù)進(jìn)行統(tǒng)計(jì)。work_area[0]為字符為空時(shí)表示統(tǒng)計(jì)結(jié)束。通過周期性的對(duì)互斥量進(jìn)行枷鎖，檢查是否已經(jīng)統(tǒng)計(jì)完。

//在線程中要執(zhí)行的代碼

void *thread_function(void * arg)

{

sleep(1);

pthread_mutex_lock(&work_mutex);

while(strcmp("end",work_area,3)! = 0)

{

printf("你輸入了%d個(gè)字符\n",strlen(work_area)-1);

work_area[0]= '\0';

pthread_mutex_unlock(&work_mutex);

while(work_area[0]=='\0')

{

thread_mutex_unlock(&work_mutex);

sleep(1);

pthread_mutex_lock(&work_mutex);

}

}

time_to_exit = 1;

work_area[0] = '\0';

pthread_mutex_unlock(&work_mutex);

pthread_exit(0);

}

在新進(jìn)程一上來之前先試圖對(duì)互斥量加鎖。如果他已經(jīng)被鎖上，新線程就會(huì)進(jìn)入堵塞狀態(tài)直到互斥鎖釋放為止，一旦可以進(jìn)入工作區(qū)。

????就首先檢查是否有退出請(qǐng)求（end）如果有，就設(shè)置time_to_exit變量和work_area，然后退出程序。

????如果沒有退出，那么就對(duì)字符個(gè)數(shù)進(jìn)行統(tǒng)計(jì)，把work_area[0]設(shè)置為空，表示統(tǒng)計(jì)工作完成，接下來就釋放互斥鎖，等待主線程的運(yùn)行，周期性地給互斥量加鎖，如果加鎖成功，就檢查主線程是否又給我們新的字符串統(tǒng)計(jì)。如果沒有，就釋放互斥鎖繼續(xù)等待。

?

轉(zhuǎn)載于:https://www.cnblogs.com/yjds/p/8598873.html

總結(jié)

以上是生活随笔為你收集整理的2.5 linux C 进程与多线程入门--（5）使用互斥量进行同步的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。