多线程异常

shizhi21cn

1. 
   
2.        #include <stdio.h>
   
3. #include <stdlib.h>
   
4. #include <errno.h>
   
5. #include <math.h>
   
6. #include <string.h>
   
7. #include <sys/types.h>
   
8. #include <netinet/in.h>
   
9. #include <sys/wait.h>
   
10. #include <unistd.h>
    
11. #define PI 3.1415926
    
12. #define TIMER0 0
    
13. #define PORT 5000                // The port which is communicate with server
    
14. #define BACKLOG 10
    
15. void nettran1(void* nsockfd);
    
16. int main (void)
    
17. {  
    
18.   int sockfd,nsockfd;
    
19.   int  opt;       
    
20.   struct sockaddr_in addr_local;
    
21.   pthread_t threadid1;       
    
22.   pthread_attr_t attr;
    
23.   struct sockaddr_in addr_remote;                  // New Socket file descriptor
    
24.   int sin_size;                // to store struct size
    
25.   sin_size = sizeof (struct sockaddr_in);
    
26.   if ((sockfd = socket (AF_INET, SOCK_STREAM, 0)) == -1)
    
27.             {   
    
28.                printf ("ERROR: Cannot obtain Socket Despcritor\n");   
    
29.                exit(1);
    
30.             }
    
31.   
    
32.            else
    
33.          
    
34.                   {
    
35.                       printf ("OK: Obtain Socket Despcritor sucessfully\n");
    
36.               }
    
37.            /* Fill the local socket address struct */
    
38.         addr_local.sin_family = AF_INET;        // Protocol Family
    
39.             addr_local.sin_port = htons (PORT);        // Port number
    
40.             addr_local.sin_addr.s_addr = INADDR_ANY;        // AutoFill local address
    
41.             bzero (&(addr_local.sin_zero), 8);        // Flush the rest of struct
    
42.             opt = SO_REUSEADDR;
    
43.   
    
44.             setsockopt (sockfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof (opt));
    
45.   
    
46.     /*  Blind a special Port */
    
47.             if (bind(sockfd, (struct sockaddr *) &addr_local, sizeof (struct sockaddr)) == -1)
    
48.              {
    
49.       
    
50.               printf ("ERROR: Cannot bind Port %d\n", PORT);
    
51.               exit(1);
    
52.              }
    
53.   
    
54.              else
    
55.    
    
56.               {
    
57.       
    
58.              printf ("OK: Bind the Port %d sucessfully\n", PORT);
    
59.    
    
60.                }
    
61.           /*  Listen remote connect/calling */
    
62.             if (listen (sockfd, BACKLOG) == -1)
    
63.             {
    
64.             printf ("ERROR: Cannot listen Port %d\n", PORT);
    
65.       
    
66.             exit(1);
    
67.    
    
68.             }
    
69.   
    
70.           else
    
71.    
    
72.             {
    
73. 
    
74.             printf ("OK: Listening the Port %d sucessfully\n", PORT);
    
75.    
    
76.             }
    
77.     while(1)
    
78.           {
    
79.            perror("Is there any error?")     ;
    
80.         /*  Wait a connection, and obtain a new socket file despriptor for single connection */
    
81.             if ((nsockfd =  accept (sockfd, (struct sockaddr *) &addr_remote,&sin_size)) != -1)       
    
82.                 {
    
83.                       printf ("OK: Server has got connect from %s   %d\n",  inet_ntoa (addr_remote.sin_addr),nsockfd);       
    
84.                  pthread_attr_init(&attr);
    
85.                  pthread_attr_setstacksize(&attr,100);   
    
86.                  perror("Is there any error1?")     ;
    
87.                  if(pthread_create(&threadid1,&attr,(void*)(nettran1),(void*)nsockfd)!=0)
    
88.                     {
    
89.                      perror("Error to create thread")     ;  
    
90.                      close (nsockfd);
    
91.                      continue;
    
92.                     }
    
93.               /*  pthread_detach(threadid1,NULL); */
    
94.                  pthread_join(threadid1,NULL);
    
95.                   }
    
96.               
    
97.             }
    
98.        //close (nsockfd);
    
99. 
    
100. }
     
101. 
     
102. void nettran1(void* nsockfd)
     
103. {
     
104. double value;
     
105. char sdbuf[8];          
     
106.   int num,i=0,sig=4;
     
107.   while(1)
     
108.                    {  
     
109.                       perror("send0:");
     
110.                       if(i++>90)     i = 0;            
     
111.                       value = sin (i * PI/ 45);  
     
112.                       perror("send1:");
     
113.                       gcvt (value, sig, sdbuf);
     
114.                       perror("send:");
     
115.                       printf("value=%s   %d\n",sdbuf,(int)nsockfd);
     
116.                      // SendMessage((HWND)hwnd,MSG_MYMESSAGE,0,0);
     
117.                       if ((num = send ((int)nsockfd,&sdbuf, sizeof (sdbuf),0)) ==-1)
     
118.                                       {   
     
119.                                perror("send:");   
     
120.                                close ((int)nsockfd)  ;
     
121.                                pthread_exit(NULL);      
     
122.                                 }
     
123.                       }
     
124. }         
     

复制代码

代码如上，多线程函数运行后，perror检测到异常：Interrupted system call。send发动不成功。

xiaozhaoz

这个程序问题必较多：
1. 无法接收多个客户端，因为创建的线程是joinable的，pthread_join()会阻塞，无法accept()更多的客户端。
2. 注意线程的stacksize是否足够。
3. send失败是因为有信号唤醒了了send的阻塞。不

xiaozhaoz

这个程序问题必较多：
1. 无法接收多个客户端，因为创建的线程是joinable的，pthread_join()会阻塞，无法accept()更多的客户端。
2. 注意线程的stacksize是否足够。
3. send失败是因为有信号唤醒了了send的阻塞。不清楚

xiaozhaoz

CU的回复总是失败，也不能在编辑！

3. send失败是因为有信号唤醒了了send的阻塞。不清楚是刚刚运行就

xiaozhaoz

第四次！

这个程序问题必较多：
1. 无法接收多个客户端，因为创建的线程是joinable的，pthread_join()会阻塞，无法accept()更多的客户端。
2. 注意线程的stacksize是否足够。
3. send失败是因为有信号唤醒了了send的阻塞。不清楚是刚刚运行就有问题，还是过一段时间才有问题。建议采用下面的方法处理：
   a). 检查errno的编号

1. 
   
2. retry:
   
3.               errno = 0;
   
4.               if ((num = send ((int)nsockfd,&sdbuf, sizeof (sdbuf),0)) ==-1)  {   
   
5.                                if(errno == EINTR)
   
6.                                       goto retry;
   
7.                                perror("send:");   
   
8.                                close ((int)nsockfd)  ;
   
9.                                pthread_exit(NULL);      
   
10.                }
    

复制代码

          b) 或者用pthread_sigmask屏蔽不必要的信号.

总体上感觉代码应该还有很多问题，需要仔细检查。