多线程异常

Question

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 Despcritorn");   
29.                exit(1);
30.             }
31.   
32.            else
33.          
34.                   {
35.                       printf ("OK: Obtain Socket Despcritor sucessfullyn");
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 %dn", PORT);
51.               exit(1);
52.              }
53.   
54.              else
55.    
56.               {
57.       
58.              printf ("OK: Bind the Port %d sucessfullyn", PORT);
59.    
60.                }
61.           /*  Listen remote connect/calling */
62.             if (listen (sockfd, BACKLOG) == -1)
63.             {
64.             printf ("ERROR: Cannot listen Port %dn", PORT);
65.       
66.             exit(1);
67.    
68.             }
69.   
70.           else
71.    
72.             {
74.             printf ("OK: Listening the Port %d sucessfullyn", 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   %dn",  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);
100. }
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   %dn",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发动不成功。

Answer 1

第四次！

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

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屏蔽不必要的信号.

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

Answer 2

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

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

Answer 3

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

Answer 4

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