2.5 linux C 进程与多线程入门--（5）使用互斥量进行同步
互斥：
簡單的理解就是一個縣城進入工作區之后，如果有其他的線程想要進入工作區，他就會進入等待狀態，要等待工作區內的線程結束后才可以進入。
基本函數：
（1）pthread_mutex_init()函數
原型： int pthread_mutex_init（phread_mutex_t *mutex,const pthread_mutexattr_t * attr）;
描述：設置互斥性的屬性
參數：第一個參數：預先聲明的pthread_mutex_t 對象指針
????????? ?第二個參數：互斥鎖屬性，null 表示使用默認屬性
返回值：成功時返回0，失敗時1返回一個錯誤代碼
（2）pthread_mutex_lock()
原型： int pthread_mutex_lock(pthread_mutex_t * mutex);
描述：pthread_mutex_lock返回時，互斥鎖被鎖定，如果這個互斥鎖被一個線程鎖定和擁有，那么另一個線程要調用這個函數會進入擁塞狀態（即等待狀態），直到互斥鎖被釋放為止。
返回值：成功時，返回0 ，失敗時 返回錯誤代碼
（3）pthread_mutex_unlock()函數
原型：int pthread_mutex_unlock(pthread_mutex_t *mutex);
描述：釋放互斥鎖
返回值：成功時返回0，失敗時返回一個錯誤代碼
（4）pthread_mutex_destroy()函數
原型：int pthread_mutex_destroy(pthread_mutex_t * mutex);
描述：刪除互斥鎖
返回值：成功時返回0 ，失敗時返回錯誤代碼
?
實例：
lock.c文件
描述：這個程序主要可以概括為主線程負責接受輸入的字符串，而子線程負責統計并輸出字符數。
#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;//創建一個線程變量
#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);
}
?
//啟動新的線程
res = pthread_create(&a_thread,????NULL, thread_function ,NULL);
if(res !=0 )
{
perror("線程創建失敗\n");
exit(1);
}
?
pthread_mutex_lock(&work_mutex);
printf("請輸入一些文本，輸入end 結束：\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("等待線程結束：...\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);
}
//主線程首先鎖定工作區，在獲取輸入的字符串后，釋放工作區，讓其它線程對字符個數進行統計。work_area[0]為字符為空時表示統計結束。通過周期性的對互斥量進行枷鎖，檢查是否已經統計完。
//在線程中要執行的代碼
void *thread_function(void * arg)
{
sleep(1);
pthread_mutex_lock(&work_mutex);
while(strcmp("end",work_area,3)! = 0)
{
printf("你輸入了%d個字符\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);
}
在新進程一上來之前先試圖對互斥量加鎖。如果他已經被鎖上，新線程就會進入堵塞狀態直到互斥鎖釋放為止，一旦可以進入工作區。
????就首先檢查是否有退出請求（end）如果有，就設置time_to_exit變量和work_area，然后退出程序。
????如果沒有退出，那么就對字符個數進行統計，把work_area[0]設置為空，表示統計工作完成，接下來就釋放互斥鎖，等待主線程的運行，周期性地給互斥量加鎖，如果加鎖成功，就檢查主線程是否又給我們新的字符串統計。如果沒有，就釋放互斥鎖繼續等待。
?
轉載于:https://www.cnblogs.com/yjds/p/8598873.html
總結
以上是生活随笔為你收集整理的2.5 linux C 进程与多线程入门--（5）使用互斥量进行同步的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： ip分组的交付
- 下一篇： Eclipse Source not f