unix网络编程中的线程池问题

kkshaq

1. * include serv08 */
   
2. #include "unpthread.h"
   
3. #include "pthread08.h"
   
4. 
   
5. static int nthreads;
   
6. pthread_mutex_t clifd_mutex = PTHREAD_MUTEX_INITIALIZER;
   
7. pthread_cond_t clifd_cond = PTHREAD_COND_INITIALIZER;
   
8. 
   
9. int
   
10. main(int argc, char **argv)
    
11. {
    
12.     int i, listenfd, connfd;
    
13.     void sig_int(int), thread_make(int);
    
14.     socklen_t addrlen, clilen;
    
15.     struct sockaddr *cliaddr;
    
16. 
    
17.     if (argc == 3)
    
18.         listenfd = Tcp_listen(NULL, argv[1], &addrlen);
    
19.     else if (argc == 4)
    
20.         listenfd = Tcp_listen(argv[1], argv[2], &addrlen);
    
21.     else
    
22.         err_quit("usage: serv08 [ ] <#threads>");
    
23.     cliaddr = Malloc(addrlen);
    
24. 
    
25.     nthreads = atoi(argv[argc-1]);
    
26. 
    
27.     tptr = Calloc(nthreads, sizeof(Thread));
    
28. 
    
29.     iget = iput = 0;
    
30. 
    
31.         /* 4create all the threads */
    
32.     for (i = 0; i < nthreads; i++)
    
33.         thread_make(i); /* only main thread returns */
    
34. 
    
35.     Signal(SIGINT, sig_int);
    
36. 
    
37.     for ( ; ; ) {
    
38.         clilen = addrlen;
    
39.         connfd = Accept(listenfd, cliaddr, &clilen);
    
40. 
    
41.         Pthread_mutex_lock(&clifd_mutex);
    
42.         clifd[iput] = connfd;
    
43.         if (++iput == MAXNCLI)
    
44.             iput = 0;
    
45.       [color=Red]  if (iput == iget)
    
46.             err_quit("iput = iget = %d", iput);         [/color]//这部分是否有缺陷？
    
47.         
    
48.       Pthread_cond_signal(&clifd_cond);
    
49.         Pthread_mutex_unlock(&clifd_mutex);
    
50.     }
    
51. }
    
52. /* end serv08 */
    
53. 
    
54. void
    
55. sig_int(int signo)
    
56. {
    
57.     int i;
    
58.     void pr_cpu_time(void);
    
59. 
    
60.     pr_cpu_time();
    
61. 
    
62.     for (i = 0; i < nthreads; i++)
    
63.         printf("thread %d, %ld connections\n", i, tptr[i].thread_count);
    
64. 
    
65.     exit(0);
    
66. }
    

复制代码

最近看unp27章中的服务器模型部分，27.12节是并发服务器程序，主线程统一accept
也就是主线程accept，worker线程工作那么模式。作者处理消费者和生产者问题的时候，使用了条件变量和互斥量达到同步。但是我觉得有些问题
作者在考虑循环队列的问题上，是采用如此的策略，在生产者函数中，如果iput==iget，必然是数组缓冲区满，作者直接采用的是、
if (iput == iget)
            err_quit("iput = iget = %d", iput);

也就是说如果生产者的速度，大于消费者的话，我们的主线程只能结束。。这个是不是有待商榷？？对应的情况就是，如果多个客户连接连续产生，工作子线程来不及处理的时候，我们的主线程就自己err_quit了。。
有没有更好的办法？（在只采用一个条件变量的条件下）