unix 多線程控制應(yīng)用

1.線程三個屬性的學(xué)習(xí)

綁定

分離

優(yōu)先級

thread.c

#include"thread.h" 
#include<stdio.h> 
#include<unistd.h> 
#include<pthread.h> 
#include<stdbool.h> 
#include<stdlib.h> 
 
extern int status_1; 
extern int status_2; 
 
void thread_0(char*pstr)//帶參數(shù) 
{ 
    int counter = 10; 
    while(counter--) 
    { 
        sleep(1); 
        printf("%s\n",pstr); 
    } 
 
    pthread_exit(&status_1);//線程退出專用函數(shù) 
} 
 
void thread_1(void)//不帶參數(shù) 
{ 
    int counter = 10; 
    while(counter--) 
    { 
        sleep(1); 
        printf("thread_1\n"); 
    } 
     
 
    pthread_exit(&status_2);//線程退出專用函數(shù) 
} 
 
 
 
bool _creat_thread(pthread_t *thread, void *(*start_routine)(void *), void *arg, int SCOPE, int DETACH, int policy, int priority_val) 
{ 
    struct sched_param param; 
    pthread_attr_t attr;     
    if(0 != pthread_attr_init(&attr))//初始化 結(jié)構(gòu)體attr， 如果不需要attr需要取消attr, pthread_attr_destroy 
    { 
        perror("pthread_attr_init\n"); 
        return false;        
    } 
     
    if(0 != pthread_attr_setscope(&attr, SCOPE))//設(shè)置線程屬性 是否綁定 綁定(PTHREAD_SCOPE_SYSTEM)  非綁定(PTHREAD_SCOPE_PROCESS) 
    { 
        perror("pthread_attr_setscope\n"); 
        return false;        
    } 
     
    if(0 != pthread_attr_setdetachstate(&attr, DETACH))//設(shè)置線程屬性 是否分離 分離（PTHREAD_CREATE_DETACHED）  非分離（PTHREAD_CREATE_JOINABLE） 
    { 
        perror("pthread_attr_setdetachstate\n"); 
        return false;    
    } 
     
    if(0 != pthread_attr_setschedpolicy(&attr, policy))//三種優(yōu)先級策略選擇 : SCHED_FIFO(值1-99), SCHED_RR(值1-99),  and SCHED_OTHER 
    { 
        perror("pead_attr_setschedpolicy\n"); 
        return false;        
    } 
         
    if(priority_val>0 && priority_val<100)//判斷優(yōu)先級值是否在1－99范圍 
    { 
        param.sched_priority = priority_val;  
    } 
    else 
    { 
        perror("priority_val_ wrong value range!!\n"); 
    } 
     
     
    if(0 != pthread_attr_setschedparam(&attr, &param))//設(shè)置設(shè)置線程屬性 優(yōu)先級 通過 策略與值來判斷如何調(diào)度 
    { 
        perror("pthread_attr_setschedparam\n"); 
        return false;    
    } 
     
    if(0 != pthread_create(thread, &attr, (void*)start_routine,arg))// 建立一個含有以上屬性的線程 
    { 
        perror("pthread_create\n"); 
        return false; 
    } 
     
    if(0 != pthread_attr_destroy(&attr))//使用完后取消attr,  
    { 
        perror("pthread_attr_destroy\n"); 
        return false;        
    } 
     
    return true; 
} 

thread.h

#ifndef THREAD_H 
#define THREAD_H 
#include<stdio.h> 
#include<pthread.h> 
#include<stdbool.h> 
 
 
void thread_0(char*); 
 
void thread_1(void); 
 
bool _creat_thread(pthread_t *,void *(*)(void *), void *, int, int, int, int); 
 
#endif //end THREAD_H 

main.c

#include"thread.h" 
#include<pthread.h> 
#include<unistd.h> 
#include<stdio.h> 
#include<stdlib.h> 
#include<stdbool.h> 
 
#define LOW_PRIO 1 
#define HIGH_PRIO 2 
 
int status_0 = 0; 
int status_1 = 1; 
int status_2 = 2; 
 
int main(void) 
{ 
    bool ret; 
    char *str = "thread_0\n"; 
    pthread_t thd0,thd1; 
 
     
    ret = _creat_thread(&thd0, (void*)thread_0, str, PTHREAD_SCOPE_SYSTEM, PTHREAD_CREATE_JOINABLE, SCHED_FIFO, LOW_PRIO);// 創(chuàng)建一個線程 帶參數(shù)級相應(yīng)屬性 
    if(ret) 
    { 
        printf("create thread successfully!\n"); 
    } 
    else 
    { 
        perror("fail to create thread!\n"); 
        exit(1); 
    } 
    ret = _creat_thread(&thd1, (void*)thread_1, NULL, PTHREAD_SCOPE_SYSTEM, PTHREAD_CREATE_JOINABLE, SCHED_FIFO, HIGH_PRIO);// 創(chuàng)建一個線程 不帶參數(shù)，含相應(yīng)屬性 
    if(ret) 
    { 
        printf("create thread successfully!\n"); 
    } 
    else 
    { 
        perror("fail to create thread!\n"); 
        exit(1); 
    } 
 
    int * thd_exit_status = NULL ; 
     
    while(1) 
    { 
        sleep(1); 
        printf("main\n"); 
         
        if(0 != pthread_join(thd0,(void**)&thd_exit_status))//if th0 no more exist, pthread_join return erro and  the thd_exit_status = NULL 
        { 
            printf("thread_0 is not exist!!\n"); 
            //exit(1); 
        } 
        else  
        { 
            if(NULL== thd_exit_status && 1 != *thd_exit_status) 
            { 
                printf("pthd0 is runing\n"); 
            } 
            else if(NULL!= thd_exit_status && 1 == *thd_exit_status) 
            { 
                printf("pthd0 has been terminated and return status:%d\n", *thd_exit_status); 
            } 
         
        } 
         
        if(0 != pthread_join(thd1,(void**)&thd_exit_status))//if th0 no more exist, pthread_join return erro and  the thd_exit_status = NULL 
        { 
            printf("thread_1 is not exist!!\n"); 
            //exit(1); 
        } 
        else 
        { 
            if(NULL == thd_exit_status && 2 != *thd_exit_status) 
            { 
                printf("pthd_1 is runing\n"); 
            } 
             
            else if(NULL!= thd_exit_status && 2 == *thd_exit_status) 
            { 
                printf("pthd_1 has been terminated and return status:%d\n", *thd_exit_status); 
            } 
        } 
    } 
     
    return 0; 
}