Linux之Ubuntu c++多线程代码demo

东方耀

Linux之Ubuntu c++多线程代码demo

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include <unistd.h>
   
5. #include <pthread.h>
   
6. 
   
7. void * Thread_collect(void *args){
   
8.     //拿到主线程传过来的参数
   
9.     int *counter_p = (int *)args;
   
10.     for(int i=0; i<5; i++){
    
11.         *counter_p = *counter_p + 2;
    
12.         printf("收集数据线程。。。%d\n", *counter_p);
    
13.         sleep(1);
    
14.     }
    
15.     return NULL;
    
16. }
    
17. 
    
18. void * Thread_process(void *args){
    
19.     int *counter_p = (int *)args;
    
20.     for(int i=0; i<6; i++){
    
21.         *counter_p = *counter_p + 1;
    
22.         printf("算法处理线程。。。%d\n", *counter_p);
    
23.         sleep(1);
    
24.     }
    
25.     return NULL;
    
26. }
    
27. 
    
28. 
    
29. 
    
30. int main(){
    
31.     //Linux之Ubuntu c++多线程代码demo
    
32.     //g++ -g -o dm dm03_雷达实时多线程.cpp -lpthread
    
33.     // ./dm执行即可
    
34. 
    
35.         //主线程：创建公共队列、维护队列、最后清空和销毁队列 创建2个子线程并维护他们的回调
    
36.         //子线程1：从usb口源源不断的实时取数据 并放队列里面
    
37.         //子线程2：从队里里拿数据 做实时信号算法处理
    
38.     int counter_common = 10;
    
39.     printf("雷达实时算法入口【Linux系统】...主线程初始计数器=%d\n", counter_common);
    
40.     //两个线程去操作 计数器 指针
    
41.     pthread_t handle_collect, handle_process;
    
42.     int err1 = pthread_create(&handle_collect,NULL,Thread_collect,&counter_common);
    
43.     int err2 = pthread_create(&handle_process,NULL,Thread_process,&counter_common);
    
44. 
    
45.     if(err1 == 0 && err2 == 0){
    
46.         printf("主线程：创建2个子线程成功！\n");
    
47.     }
    
48.     //主线程要等到创建的线程返回了，获取该线程的返回值后主线程才退出
    
49.     // 只等待子线程，但是不关心子线程的退出值
    
50.     pthread_join(handle_collect, NULL);
    
51.     pthread_join(handle_process, NULL);
    
52.     printf("等所有子线程执行完毕.。。再回到主线程，再看计数器=%d\n", counter_common);
    
53.     return 0;
    
54. }

复制代码