linux c 多線程編程實例
時間：2018-01-26 來源：未知
在主流的操作系統中，多任務一般都提供了進程和線程兩種實現方式，進程享有獨立
的進程空間，而線程相對于進程來說是一種更加輕量級的多任務并行，多線程之間一般都是共
享所在進程的內存空間的。
Linux也不例外，雖然從內核的角度來看，線程體現為一種對進程的"克隆"(clone),共
享進程的資源。但是在用戶空間提供了線程管理機制來實現對線程的管理，目前Linux中流行
的線程機制為LinuxThreads，下面以一個多線程編程實例來介紹該線程庫的編程接口：
示例1:線程的創建和退出，等待線程結束和獲取線程的返回值
#include
#include
#include
/************************************************************
*線程函數：線程運行執行的函數
*參數p:通用類型的指針，啟動線程時傳遞給線程函數的參數
*返回值:通用類型指針，線程結束后啟動線程的函數可以獲取該值
*************************************************************/
void* task(void* p){
double r = *(double*)p;
printf("%lf\n",3.14*r*r);
}
void* task2(void* p){
static int sum = 0;
int i;
for(i=1;i<11;i++)
sum = sum+i;
return ∑
//pthread_exit(&sum);線程退出，和return等價
}
int main(){
pthread_t id1,id2;
double d = 1.0;
int* pi = NULL;
/*
*創建線程函數，在主線程中調用該函數可以創建線程
*參數1:線程ID，ID由系統分配，該參數是一個傳出參數，類型為pthread_t *
*參數2:線程屬性，使用默認屬性給0即可，類型為pthread_attr_t *
*參數3:線程函數，即線程運行時代碼，類型為void *(*)(void *)
*參數4:傳遞給線程函數的參數
*/
pthread_create(&id1,0,task,&d);//計算圓的面積
pthread_create(&id2,0,task2,0);//計算累加和
/*
*等待線程結束函數，用于在一個線程中等待另外一個線程結束
*參數1:要等待結束的線程的ID
*參數2:結束線程的返回值的地址(由于是傳出參數，所以是返回值的地址)
*/
pthread_join(id1,0);
pthread_join(id2,(void**)&pi);//pi=∑
printf("sum=%d\n",*pi);
return 0;
}
此外，我們還可以設置線程的屬性，下面介紹設置線程分離屬性的代碼
示例2:設置線程的分離屬性
#include
#include
//線程函數
void* task(void* p){
int i;
for(i=0;i<50;i++){
printf("%d\n",i);
usleep(100000);//0.1秒
}
}
int main(){
pthread_t id;
pthread_create(&id,0,task,0);
/*
*將線程設置為分離屬性，分離屬性的線程一旦結束，直接回收資源
*因此當線程設置為分離屬性后將無法再等待線程結束和獲取線程的返回值
*參數:設置分離屬性的線程ID
*/
pthread_detach(id);//detach的線程join
//pthread_join(id,0);//無效
int i;
for(i=0;i<50;i++){
printf("main:%d\n",i);
usleep(100000);//0.1秒
}
}
由于多線程之間是共享進程資源的，所以多線程編程時需要對共享資源的訪問進行保護
包括互斥和同步，常用的方式包括互斥鎖和信號量
示例3：互斥鎖的使用
#include
#include
char* data[5];//定義一個長度是5字符串數組
int size = 0;//定義了當前下標,也是人數
pthread_mutex_t lock;//1 聲明
void* task(void* p){
pthread_mutex_lock(&lock);//3 加鎖
data[size] = (char*)p; //4 訪問共享資源
usleep(10000); ++size;
pthread_mutex_unlock(&lock);//5 解鎖
}
int main(){
data[size] = "liubei"; size++;
pthread_mutex_init(&lock,0);//2 初始化
pthread_t id1,id2;
pthread_create(&id1,0,task,"zhangfei");
pthread_create(&id2,0,task,"guanyu");
pthread_join(id1,0);
pthread_join(id2,0);
pthread_mutex_destroy(&lock);//6 刪除
int i;
for(i=0;i
printf("%s\n",data[i]);
}
示例4:信號量的使用
#include
#include
#include
#include
sem_t sem; //1 分配
void* task(void* p){
int i = (int)p;
printf("第%d個線程申請連接\n",i);
sem_wait(&sem);//3 P操作(計數-1)
printf("第%d個線程申請成功\n",i);
srand(time(0));//4 模擬訪問共享資源
sleep(rand()%10);
printf("第%d個線程釋放資源\n",i);
sem_post(&sem);//5 V操作(計數+1)
}
int main(){
sem_init(&sem,0,10);//2 初始化
int i;
for(i=1;i<16;i++){
pthread_t id;
pthread_create(&id,0,task,(void*)i);
}
while(1);
}
