求助：生产者/消费者通过buffer通讯的问题

小飞爱使申华

生产者，2个线程
消费者，2个线程
想通过buffer把string“Hello World”的字符打印到stdout，现程序compile通过，可运行没结果，请大家帮忙看看。
   

1. /*
   
2.    The size of buffer is more than one. Multiple producers, multiple consumers
   
3. */
   
4. 
   
5. #include <stdio.h>;
   
6. #include <pthread.h>;
   
7. 
   
8. #define N_PRODUCERS 2    /* the number of producers */
   
9. #define N_CONSUMERS 2    /* the number of consumers */
   
10. #define BUFFER_SIZE 3    /* the size of the buffer  */
    
11. 
    
12. int  count = 0;          /* the number of data items in the buffer */
    
13. char buf[BUFFER_SIZE];   /* the buffer (circular buffer) */
    
14. int  head = 0;           /* index of the head data in the buffer */
    
15. int  tail = 0;           /* index of the tail data in the buffer */
    
16. 
    
17. pthread_cond_t  empty, full;
    
18. pthread_mutex_t buf_mutex_lock, produced_lock, consumed_lock;
    
19. 
    
20. char *message = "Hello_world.";
    
21. 
    
22. 
    
23. void get_from_buf(char *ch)
    
24. {
    
25.    while (count == 0)
    
26.    {
    
27.       /* Wait until producer adds something */
    
28.       pthread_cond_wait(&full, &consumed_lock);  
    
29.    }
    
30. 
    
31.    pthread_mutex_lock(&buf_mutex_lock);
    
32.    *ch = buf[head];
    
33.    head = (head+1) % BUFFER_SIZE;
    
34.    count--;
    
35.    pthread_mutex_unlock(&buf_mutex_lock);
    
36.    pthread_cond_signal(&empty);
    
37. }
    
38. 
    
39. 
    
40. void put_to_buf(char *ch)
    
41. {
    
42.    char *p = message;
    
43.    
    
44.    while (count == BUFFER_SIZE)
    
45.    {
    
46.       /* Wait until a consumer removes something. */
    
47.       pthread_cond_wait(&empty, &produced_lock);
    
48.    }
    
49. 
    
50.    pthread_mutex_lock(&buf_mutex_lock);
    
51.    buf[tail] = *ch = *(p++);
    
52.    tail = (tail+1) % BUFFER_SIZE;
    
53.    count++;
    
54.    pthread_mutex_unlock(&buf_mutex_lock);
    
55.    pthread_cond_signal(&full);
    
56. }
    
57. 
    
58. 
    
59. /*****************************************************************
    
60. Producer
    
61. *****************************************************************/
    
62. void producer(void)
    
63. {
    
64.    char ch;
    
65.    
    
66.    do
    
67.    {
    
68.       pthread_mutex_lock(&produced_lock);
    
69.       put_to_buf(&ch);
    
70.       pthread_mutex_unlock(&produced_lock);
    
71.    } while (ch != '\0');
    
72.    pthread_exit(NULL);
    
73. }
    
74. 
    
75. 
    
76. /*****************************************************************
    
77. Consumer
    
78. *****************************************************************/
    
79. void consumer(void)
    
80. {
    
81.    char ch;
    
82.    
    
83.    do
    
84.    {
    
85.       pthread_mutex_lock(&consumed_lock);
    
86.       get_from_buf(&ch);
    
87.       if (ch != '\0')                  /* print the character */
    
88.          printf("%c ", ch);
    
89.       pthread_mutex_unlock(&consumed_lock);
    
90.    } while (ch != '\0');
    
91.    pthread_exit(NULL);
    
92. }
    
93. 
    
94. 
    
95. int main(int argc, char **argv)
    
96. {
    
97.    int i;
    
98.    
    
99.    pthread_t producer_threads[N_PRODUCERS];
    
100.    pthread_t consumer_threads[N_CONSUMERS];
     
101.    pthread_attr_t attr;
     
102.    pthread_attr_init(&attr);
     
103.    pthread_mutex_init(&buf_mutex_lock, NULL);
     
104.    pthread_mutex_init(&produced_lock, NULL);
     
105.    pthread_mutex_init(&consumed_lock, NULL);
     
106.    pthread_cond_init(&empty, NULL);
     
107.    pthread_cond_init(&full, NULL);
     
108. 
     
109. 
     
110.    /* Create producers. */
     
111.    for (i = 0; i < N_PRODUCERS; i++)
     
112.    {        
     
113.       if (pthread_create(&producer_threads[i], &attr, (void*) &producer, NULL) != 0)
     
114.       {
     
115.                 /* Error. */
     
116.       }
     
117.    }
     
118. 
     
119.    /* Create consumers. */
     
120.    for (i = 0; i < N_CONSUMERS; i++)
     
121.    {
     
122.       if (pthread_create(&consumer_threads[i], &attr, (void*)&consumer, NULL) != 0)
     
123.       {
     
124.                  /* Error. */
     
125.       }
     
126.    }
     
127. 
     
128.    /* Wait for them to finish. */
     
129.    for (i = 0; i < N_CONSUMERS; i++)
     
130.    {
     
131.       pthread_join(producer_threads[i], NULL);
     
132.       pthread_join(consumer_threads[i], NULL);
     
133.    }
     
134. 
     
135.    /* We're done. */
     
136.    return 0;
     
137. }

复制代码

gadfly

你上面有一个问题，那就是put_to_buf中，p是局部量，退出后，上次的状态就消失了。

所以，你的结果就会都是H H.....

因此，你可以改成

1. 
   
2. static char *p = message;
   

复制代码

就ok了。

JohnBull

提醒一句：
线程中如果使用了static变量，编程的时候要注意不要发生重入。

gadfly

对，上面的例子中那个buf_lock_mutex就起了防止重入的作用。

小飞爱使申华

俺这阵子跟unix底层system call干上了，多谢各位捧场！

蓝色键盘

呵呵，投你一票。。。

sunlan

加信号灯