unix 多线程控制应用

1.线程三个属性的学习

绑定

分离

优先级

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)//带参数 
{ 
    int counter = 10; 
    while(counter--) 
    { 
        sleep(1); 
        printf("%s\n",pstr); 
    } 
 
    pthread_exit(&status_1);//线程退出专用函数 
} 
 
void thread_1(void)//不带参数 
{ 
    int counter = 10; 
    while(counter--) 
    { 
        sleep(1); 
        printf("thread_1\n"); 
    } 
     
 
    pthread_exit(&status_2);//线程退出专用函数 
} 
 
 
 
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))//初始化 结构体attr， 如果不需要attr需要取消attr, pthread_attr_destroy 
    { 
        perror("pthread_attr_init\n"); 
        return false;        
    } 
     
    if(0 != pthread_attr_setscope(&attr, SCOPE))//设置线程属性 是否绑定 绑定(PTHREAD_SCOPE_SYSTEM)  非绑定(PTHREAD_SCOPE_PROCESS) 
    { 
        perror("pthread_attr_setscope\n"); 
        return false;        
    } 
     
    if(0 != pthread_attr_setdetachstate(&attr, DETACH))//设置线程属性 是否分离 分离（PTHREAD_CREATE_DETACHED）  非分离（PTHREAD_CREATE_JOINABLE） 
    { 
        perror("pthread_attr_setdetachstate\n"); 
        return false;    
    } 
     
    if(0 != pthread_attr_setschedpolicy(&attr, policy))//三种优先级策略选择 : 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)//判断优先级值是否在1－99范围 
    { 
        param.sched_priority = priority_val;  
    } 
    else 
    { 
        perror("priority_val_ wrong value range!!\n"); 
    } 
     
     
    if(0 != pthread_attr_setschedparam(&attr, &param))//设置设置线程属性 优先级 通过 策略与值来判断如何调度 
    { 
        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);// 创建一个线程 带参数级相应属性 
    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);// 创建一个线程 不带参数，含相应属性 
    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; 
}