多线程(生产者-消费者), 怎么只有一个生产者运行,其它的怎么了??

weckay

现在学习UNPV2的互斥锁时需要用多线程来模拟经典的生产者-消费者问题.但是我试图生成10个生产者,但是程序运行结果显示只有一个生产者运行了,pthread_setconcurrency(10)也调用了,什么原因呢?
我的系统是FC5 2.6.15的内核.代码如下:

1. #include "ourhdr.h"
   
2. 
   
3. #define MAXNITEMS 1000000
   
4. #define MAXNTHREADS   100
   
5. 
   
6. int nitems;
   
7. 
   
8. struct {
   
9.     pthread_mutex_t mutex;
   
10.     int buf[MAXNITEMS];
    
11.     int nput;
    
12.     int nval;
    
13. } shared = {
    
14.     PTHREAD_MUTEX_INITIALIZER
    
15. };
    
16. 
    
17. void *produce(void *);
    
18. void *consume(void *);
    
19. 
    
20. int main(int argc, char *argv[])
    
21. {
    
22.     int i, nthreads, count[MAXNTHREADS];
    
23.     pthread_t tid_produce[MAXNTHREADS], tid_consume;
    
24.     if (argc != 3)
    
25.         err_quit("usage: prodcons2 <#items> <#threads>");
    
26.     nitems = min(atoi(argv[1]), MAXNITEMS);
    
27.     nthreads = min(atoi(argv[2]), MAXNTHREADS);
    
28. 
    
29.     pthread_setconcurrency(nthreads); //设置并发级别,怎么不起作用??
    
30.     for (i = 0; i < nthreads; i++) {
    
31.         count[i] = 0;
    
32.         pthread_create(&tid_produce[i], NULL, produce, &count[i]);
    
33.     }
    
34. 
    
35.     for (i = 0; i < nthreads; i++) {
    
36.         pthread_join(tid_produce[i], NULL);
    
37.         printf("count[%d] = %d\n", i, count[i]);
    
38.     }
    
39. 
    
40.     pthread_create(&tid_consume, NULL, consume, NULL);
    
41.     pthread_join(tid_consume, NULL);
    
42.     exit(0);
    
43. }
    
44. 
    
45. void *produce(void *arg)
    
46. {
    
47.     for (; ;) {
    
48.         pthread_mutex_lock(&shared.mutex);
    
49.         if (shared.nput >= nitems) {
    
50.             pthread_mutex_unlock(&shared.mutex);
    
51.             return NULL;
    
52.         }
    
53.         shared.buf[shared.nput] = shared.nval;
    
54.         shared.nput++;
    
55.         shared.nval++;
    
56.         pthread_mutex_unlock(&shared.mutex);
    
57.         *((int *)arg) += 1;
    
58.     }
    
59. }
    
60. 
    
61. void *consume(void *arg)
    
62. {
    
63.     int i;
    
64.     for (i = 0; i < nitems; i++) {
    
65.         if (shared.buf[i] != i)
    
66.             printf("buf[%d] = %d\n", i, shared.buf[i]);
    
67.     }
    
68. 
    
69.     return NULL;
    
70. }

复制代码

还请各位帮忙指点一下.谢谢!

我的运行情况如下:

1. [weckay@ mutex]$ ./prodcons2 10000 10
   
2. count[0] = 10000
   
3. count[1] = 0
   
4. count[2] = 0
   
5. count[3] = 0
   
6. count[4] = 0
   
7. count[5] = 0
   
8. count[6] = 0
   
9. count[7] = 0
   
10. count[8] = 0
    
11. count[9] = 0

复制代码

[ 本帖最后由 weckay 于 2007-5-18 15:33 编辑 ]

wuxiangzhi

说明你计算机NB撒，还没等第二个线程启动，第一个线程就加到10000了，所以后面的线程没活干咯。在线程函数里sleep一下，就OK了。

weckay

偶试了一下,用1000000 10就能看出效果了.
不好意思~~~~