C 多线程，执行异常了，顺序影响执行结果？

sasinop

执行结果：



代码中，在udp_process();里封装了一个UDP的接受代码（网上找到），函数启动了一个线程。

将该udp_process();函数，放在两个打印字符的线程，后面执行，结果如上图，三个线程都正常工作

1. void main(int argc, char **argv)
   
2. {       
   
3.          initMutex();
   
4.          initial_udp();
   
5.          
   
6.                
   
7.                 //udp_process();
   
8.                  /*
   
9.         初始化属性值，均设为默认值
   
10.         */   
    
11.          
    
12.         pthread_attr_init(&attr2);
    
13.         pthread_attr_setscope(&attr2, PTHREAD_SCOPE_SYSTEM);        
    
14.         pthread_attr_setdetachstate(&attr2, PTHREAD_CREATE_DETACHED);
    
15.                
    
16.                  if(pthread_create(&thread_loop_print,&attr2,(void*)pthread_handle_message2,NULL))
    
17.     {
    
18.             perror("pthread_creat error!");
    
19.       exit(-1);
    
20.     }
    
21.    
    
22.      if(pthread_create(&thread_loop_print2,&attr2,(void*)pthread_handle_message3,NULL))
    
23.     {
    
24.             perror("pthread_creat error!");
    
25.       exit(-1);
    
26.     }
    
27.    
    
28.                  udp_process();
    
29.                  
    
30.                  pthread_join (thread_loop_print, NULL);
    
31.                  pthread_join (thread_loop_print2, NULL);
    
32.                  pthread_join (thread_udp_process, NULL);
    
33.           while(1)
    
34.      {
    
35.              sleep(1);
    
36.              }
    
37.           //return 0;
    
38.        
    
39. }

复制代码

在代码中，
udp_process();函数先执行时， 结果如下图：
两个打印字符串的线程，没有执行,, 只有处理UDP 数据包的 线程正确执行，

顺序很有影响么？

sasinop

1. 
   
2. #include "udp.h"
   
3. 
   
4. 
   
5.   /*
   
6.   创建 EPOLL 句柄，
   
7.   */
   
8. 
   
9. int create_epoll_udp(unsigned int event_num)
   
10. {
    
11.         int epoll_fd;
    
12.        
    
13.         epoll_fd= epoll_create(event_num);  
    
14.   len = sizeof(struct sockaddr_in);
    
15.   ev.events = EPOLLIN | EPOLLET;
    
16.   ev.data.fd = listener;
    
17.   if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listener, &ev) < 0)
    
18.   {
    
19.     fprintf(stderr, "epoll set insertion error: fd=%d \n", listener);
    
20.     return -1;
    
21.   }
    
22.   else
    
23.   {
    
24.     printf("socket adding in  epoll success! \n");
    
25.   }
    
26.   
    
27.         return epoll_fd;
    
28.        
    
29.         }
    
30.        
    
31. 
    
32.        
    
33.        
    
34. /*
    
35. setnonblocking--设置具备为非阻塞方式
    
36. */
    
37. int setnonblocking(int sockfd)
    
38. {
    
39.   if (fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFD, 0)|O_NONBLOCK) == -1)
    
40.   {
    
41.     return -1;
    
42.   }
    
43.   return 0;
    
44. }
    
45. 
    
46. 
    
47. /*
    
48. pthread_handle_message --线程处理 socket上的消息收发
    
49.   */
    
50.   
    
51. void* pthread_handle_message2()
    
52. {
    
53.         while(1){
    
54.                 printf("this is thread 2!\n");
    
55.                 fflush(stdout);
    
56.                 sleep(1);
    
57.                 //pthread_exit(NULL);
    
58.         }
    
59. }
    
60. void* pthread_handle_message3()
    
61. {
    
62.         while(1){
    
63.                 printf("this is thread 3!\n");
    
64.                 printf("\n");
    
65.                 fflush(stdout);
    
66.                 sleep(3);
    
67.                 //pthread_exit(NULL);
    
68.         }
    
69. }
    
70. 
    
71. void* pthread_handle_message(int* sock_fd)
    
72. {
    
73.         int i;
    
74.         int ret_data_len;
    
75.   unsigned char recvbuf[MAXBUF + 1];
    
76.   unsigned char sendbuf[MAXBUF+1];
    
77.   int  ret;
    
78.   int  new_fd;
    
79.   struct sockaddr_in client_addr;
    
80.   socklen_t cli_len=sizeof(client_addr);
    
81.   new_fd=*sock_fd;
    
82. 
    
83.   /*
    
84.   
    
85.   开始处理每个新连接上的数据收发
    
86.   */
    
87.   bzero(recvbuf, MAXBUF + 1);
    
88.   bzero(sendbuf, MAXBUF + 1);
    
89. 
    
90.   /*
    
91.   接收客户端的消息
    
92.   */
    
93.   
    
94.   
    
95.   ret = recvfrom(new_fd, recvbuf, MAXBUF, 0, (struct sockaddr *)&client_addr, &cli_len);
    
96.   if (ret > 0)
    
97.           {
    
98.             printf("socket %d recv from : %s : %d message: %s  %d bytes \n",
    
99.            new_fd, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), recvbuf, ret);
    
100.              printf("Hex bytes: \n");
     
101.             
     
102.              if(recvbuf[0]==0x40)
     
103.                      {       
     
104.                              for(i=0;i<recvbuf[1]+2;i++)
     
105.                               printf("%02X",recvbuf[i]);
     
106.                              printf("\n");       
     
107.                              printf("\n");       
     
108.                              if(recvbuf[2]==CMD_GET_VERSION)
     
109.                                      {
     
110.                                              ret_data_len = getVersionInfo(sendbuf);                                                    
     
111.                                      }
     
112.                      }
     
113.              printf("Data length:%d \n",ret_data_len);
     
114.              for(i=0;i<ret_data_len;i++)
     
115.                      printf("%02X ",sendbuf[i]);
     
116.      
     
117.              printf("\n");       
     
118.              printf("\n");       
     
119.              printf("\n");       
     
120. 
     
121.    ret = sendto(new_fd, sendbuf, sendbuf[1]+2, 0, (struct sockaddr *)&client_addr, cli_len);
     
122.    if(ret<0)
     
123.     printf("消息发送失败！错误代码是%d，错误信息是'%s'/n", errno, strerror(errno));
     
124.   }
     
125.   else
     
126.   {
     
127.     printf("received failed! error code %d ??message : %s \n",errno, strerror(errno));   
     
128.   }
     
129.   
     
130.   /*
     
131.   处理每个新连接上的数据收发结束
     
132.   */
     
133.   //printf("pthread exit!");
     
134.   fflush(stdout);
     
135.   sleep(1);
     
136.   //pthread_exit(NULL);
     
137.   
     
138. }
     
139. 
     
140. 
     
141. 
     
142. void initial_udp()
     
143. {
     
144.   /*
     
145.   设置每个进程允许打开的最大文件数
     
146.   */
     
147.   
     
148.   rt.rlim_max = rt.rlim_cur = MAXEPOLLSIZE;
     
149.   if (setrlimit(RLIMIT_NOFILE, &rt) == -1)
     
150.   {
     
151.     perror("setrlimit error!\n");
     
152.     exit(1);
     
153.   }
     
154.   else
     
155.   {
     
156.     printf("setting rlimit success! \n");
     
157.   }
     
158. 
     
159.   /*
     
160.   开启 socket 监听
     
161.   */
     
162.   
     
163.   if ((listener = socket(PF_INET, SOCK_DGRAM, 0)) == -1)
     
164.   {
     
165.     perror("socket create failed!\n");
     
166.     exit(1);
     
167.   }
     
168.   else
     
169.   {
     
170. 
     
171.     printf("Starting listening \n");
     
172.   }
     
173.   
     
174.   /*
     
175.   设置 socket属性，端口可以重用
     
176.   */
     
177.   
     
178.   int opt=SO_REUSEADDR;
     
179.   setsockopt(listener,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
     
180. 
     
181. 
     
182.   setnonblocking(listener);
     
183.   bzero(&my_addr, sizeof(my_addr));
     
184.   my_addr.sin_family = PF_INET;
     
185.   my_addr.sin_port = htons(HOST_PORT);
     
186. 
     
187.   my_addr.sin_addr.s_addr = inet_addr(HOST_IP_ADDRESS);
     
188. 
     
189.   if (bind(listener, (struct sockaddr *) &my_addr, sizeof(struct sockaddr)) == -1)
     
190.   {
     
191. 
     
192.           printf("socket : %s   \n", inet_ntoa(my_addr.sin_addr));
     
193.     perror("bind error! \n");
     
194.     exit(1);
     
195.   }
     
196.   else
     
197.   {
     
198.     printf("IP and port bind ： \n");
     
199.                 printf("IP  : %s   \n", inet_ntoa(my_addr.sin_addr));
     
200.     printf("port: %d \n",ntohs(my_addr.sin_port));
     
201.   }
     
202.        
     
203.         }
     
204.        
     
205.        
     
206.        
     
207.        
     
208.         void close_udp(unsigned int listen)
     
209. {
     
210.          close(listen);
     
211.                
     
212.         }
     
213. 
     
214. 
     
215.        
     
216. void create_epoll_events_udp(unsigned int events_fd)
     
217. {
     
218. 
     
219.   while (1)
     
220.   {
     
221.    /*
     
222.             等待有事件发生
     
223.     */
     
224.    
     
225.     printf("kdpfd values: %d \n",events_fd);
     
226.     nfds = epoll_wait(events_fd, events, 10,-1 );
     
227.     printf("nfds values: %d \n",nfds);       
     
228.     if (nfds == -1)
     
229.     {
     
230.       perror("epoll_wait error! \n");
     
231.       break;
     
232.     }
     
233.    
     
234.     /*
     
235.     处理所有事件
     
236.     */
     
237.    
     
238.     for (n = 0; n < nfds; ++n)
     
239.     {
     
240.       if (events[n].data.fd == listener)
     
241.       {
     
242.         /*
     
243.         初始化属性值，均设为默认值
     
244.         */
     
245.         
     
246.         pthread_attr_init(&attr);
     
247.         pthread_attr_setscope(&attr, PTHREAD_SCOPE_SYSTEM);
     
248. 
     
249. 
     
250.         /*
     
251.         设置线程为分离属性
     
252.         */
     
253.         
     
254.         pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
     
255.                                
     
256.         if(pthread_create(&thread_udp_process,&attr,(void*)pthread_handle_message,(void*)&(events[n].data.fd)))
     
257.         {
     
258.            perror("pthread_creat error!");
     
259.            exit(-1);
     
260.         }      
     
261.        }
     
262.      }
     
263.      //sleep(1);
     
264.   }       
     
265.   
     
266.   close_udp(listener);
     
267. 
     
268.         }
     
269.        
     
270. 
     
271. void udp_process()
     
272. {
     
273.                 kdpfd=create_epoll_udp(MAXEPOLLSIZE);
     
274.   create_epoll_events_udp(kdpfd);
     
275.   
     
276.         }
     
277. 
     

复制代码

UDP部分，网上找的的参考代码，简单修改了一下