189 8069 5689

unix多线程控制应用

1.线程三个属性的学习

新宾ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为创新互联的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：13518219792（备注：SSL证书合作）期待与您的合作！

绑定

分离

优先级

thread.c


  1. #include"thread.h" 
  2. #include 
  3. #include 
  4. #include 
  5. #include 
  6. #include 
  7.  
  8. extern int status_1; 
  9. extern int status_2; 
  10.  
  11. void thread_0(char*pstr)//带参数 
  12. { 
  13.     int counter = 10; 
  14.     while(counter--) 
  15.     { 
  16.         sleep(1); 
  17.         printf("%s\n",pstr); 
  18.     } 
  19.  
  20.     pthread_exit(&status_1);//线程退出专用函数 
  21. } 
  22.  
  23. void thread_1(void)//不带参数 
  24. { 
  25.     int counter = 10; 
  26.     while(counter--) 
  27.     { 
  28.         sleep(1); 
  29.         printf("thread_1\n"); 
  30.     } 
  31.      
  32.  
  33.     pthread_exit(&status_2);//线程退出专用函数 
  34. } 
  35.  
  36.  
  37.  
  38. bool _creat_thread(pthread_t *thread, void *(*start_routine)(void *), void *arg, int SCOPE, int DETACH, int policy, int priority_val) 
  39. { 
  40.     struct sched_param param; 
  41.     pthread_attr_t attr;     
  42.     if(0 != pthread_attr_init(&attr))//初始化 结构体attr， 如果不需要attr需要取消attr, pthread_attr_destroy 
  43.     { 
  44.         perror("pthread_attr_init\n"); 
  45.         return false;        
  46.     } 
  47.      
  48.     if(0 != pthread_attr_setscope(&attr, SCOPE))//设置线程属性 是否绑定 绑定(PTHREAD_SCOPE_SYSTEM)  非绑定(PTHREAD_SCOPE_PROCESS) 
  49.     { 
  50.         perror("pthread_attr_setscope\n"); 
  51.         return false;        
  52.     } 
  53.      
  54.     if(0 != pthread_attr_setdetachstate(&attr, DETACH))//设置线程属性 是否分离 分离（PTHREAD_CREATE_DETACHED）  非分离（PTHREAD_CREATE_JOINABLE） 
  55.     { 
  56.         perror("pthread_attr_setdetachstate\n"); 
  57.         return false;    
  58.     } 
  59.      
  60.     if(0 != pthread_attr_setschedpolicy(&attr, policy))//三种优先级策略选择 : SCHED_FIFO(值1-99), SCHED_RR(值1-99),  and SCHED_OTHER 
  61.     { 
  62.         perror("pead_attr_setschedpolicy\n"); 
  63.         return false;        
  64.     } 
  65.          
  66.     if(priority_val>0 && priority_val<100)//判断优先级值是否在1－99范围 
  67.     { 
  68.         param.sched_priority = priority_val;  
  69.     } 
  70.     else 
  71.     { 
  72.         perror("priority_val_ wrong value range!!\n"); 
  73.     } 
  74.      
  75.      
  76.     if(0 != pthread_attr_setschedparam(&attr, ¶m))//设置设置线程属性 优先级 通过 策略与值来判断如何调度 
  77.     { 
  78.         perror("pthread_attr_setschedparam\n"); 
  79.         return false;    
  80.     } 
  81.      
  82.     if(0 != pthread_create(thread, &attr, (void*)start_routine,arg))// 建立一个含有以上属性的线程 
  83.     { 
  84.         perror("pthread_create\n"); 
  85.         return false; 
  86.     } 
  87.      
  88.     if(0 != pthread_attr_destroy(&attr))//使用完后取消attr,  
  89.     { 
  90.         perror("pthread_attr_destroy\n"); 
  91.         return false;        
  92.     } 
  93.      
  94.     return true; 
  95. } 


thread.h



  1. #ifndef THREAD_H 
  2. #define THREAD_H 
  3. #include 
  4. #include 
  5. #include 
  6.  
  7.  
  8. void thread_0(char*); 
  9.  
  10. void thread_1(void); 
  11.  
  12. bool _creat_thread(pthread_t *,void *(*)(void *), void *, int, int, int, int); 
  13.  
  14. #endif //end THREAD_H 

main.c

  1. #include"thread.h" 
  2. #include 
  3. #include 
  4. #include 
  5. #include 
  6. #include 
  7.  
  8. #define LOW_PRIO 1 
  9. #define HIGH_PRIO 2 
  10.  
  11. int status_0 = 0; 
  12. int status_1 = 1; 
  13. int status_2 = 2; 
  14.  
  15. int main(void) 
  16. { 
  17.     bool ret; 
  18.     char *str = "thread_0\n"; 
  19.     pthread_t thd0,thd1; 
  20.  
  21.      
  22.     ret = _creat_thread(&thd0, (void*)thread_0, str, PTHREAD_SCOPE_SYSTEM, PTHREAD_CREATE_JOINABLE, SCHED_FIFO, LOW_PRIO);// 创建一个线程 带参数级相应属性 
  23.     if(ret) 
  24.     { 
  25.         printf("create thread successfully!\n"); 
  26.     } 
  27.     else 
  28.     { 
  29.         perror("fail to create thread!\n"); 
  30.         exit(1); 
  31.     } 
  32.     ret = _creat_thread(&thd1, (void*)thread_1, NULL, PTHREAD_SCOPE_SYSTEM, PTHREAD_CREATE_JOINABLE, SCHED_FIFO, HIGH_PRIO);// 创建一个线程 不带参数，含相应属性 
  33.     if(ret) 
  34.     { 
  35.         printf("create thread successfully!\n"); 
  36.     } 
  37.     else 
  38.     { 
  39.         perror("fail to create thread!\n"); 
  40.         exit(1); 
  41.     } 
  42.  
  43.     int * thd_exit_status = NULL ; 
  44.      
  45.     while(1) 
  46.     { 
  47.         sleep(1); 
  48.         printf("main\n"); 
  49.          
  50.         if(0 != pthread_join(thd0,(void**)&thd_exit_status))//if th0 no more exist, pthread_join return erro and  the thd_exit_status = NULL 
  51.         { 
  52.             printf("thread_0 is not exist!!\n"); 
  53.             //exit(1); 
  54.         } 
  55.         else  
  56.         { 
  57.             if(NULL== thd_exit_status && 1 != *thd_exit_status) 
  58.             { 
  59.                 printf("pthd0 is runing\n"); 
  60.             } 
  61.             else if(NULL!= thd_exit_status && 1 == *thd_exit_status) 
  62.             { 
  63.                 printf("pthd0 has been terminated and return status:%d\n", *thd_exit_status); 
  64.             } 
  65.          
  66.         } 
  67.          
  68.         if(0 != pthread_join(thd1,(void**)&thd_exit_status))//if th0 no more exist, pthread_join return erro and  the thd_exit_status = NULL 
  69.         { 
  70.             printf("thread_1 is not exist!!\n"); 
  71.             //exit(1); 
  72.         } 
  73.         else 
  74.         { 
  75.             if(NULL == thd_exit_status && 2 != *thd_exit_status) 
  76.             { 
  77.                 printf("pthd_1 is runing\n"); 
  78.             } 
  79.              
  80.             else if(NULL!= thd_exit_status && 2 == *thd_exit_status) 
  81.             { 
  82.                 printf("pthd_1 has been terminated and return status:%d\n", *thd_exit_status); 
  83.             } 
  84.         } 
  85.     } 
  86.      
  87.     return 0; 
  88. } 

 

附件：http://down.51cto.com/data/2362156

网页题目：unix多线程控制应用
当前地址：http://ptruijie.cn/article/joipec.html

其他资讯