两个线程实现文件写入，编译通过，可是提示段错误郁闷

373202184

1. #include <stdio.h>
   
2. #include <pthread.h>
   
3. #include <unistd.h>
   
4. #include <stdlib.h>
   
5. 
   
6. #define BUFFER_SIZE 10
   
7. 
   
8. int buffer[BUFFER_SIZE];
   
9. int in = 0;
   
10. int out = 0;
    
11. int nextProduced;
    
12. int nextConsumed;
    
13.        
    
14. void thread_producer(int *);
    
15. void thread_consumer(int *,FILE * );
    
16. 
    
17. int main(void)
    
18. {
    
19.         FILE *fout;
    
20.         fout = fopen("data.out","w");
    
21.         pthread_t producer_id;
    
22.         pthread_t consumer_id;
    
23.         int ret_p, ret_c;
    
24.         ret_p = pthread_create(&producer_id,NULL,(void *) thread_producer,NULL);
    
25.         ret_c = pthread_create(&consumer_id,NULL,(void *) thread_consumer,NULL);
    
26.         if(ret_p!=0)
    
27.         {
    
28.                 printf("Create thread_producer failed.\n");
    
29.                 exit(1);
    
30.         }
    
31.         if(ret_c!=0)
    
32.         {
    
33.                 printf("Create thread_consumer failed.\n");
    
34.                 exit(1);
    
35.         }
    
36.         pthread_join(producer_id,NULL);
    
37.         pthread_join(consumer_id,NULL);
    
38.         fclose(fout);
    
39.         return 0;
    
40. }
    
41. 
    
42. void thread_producer(int* buffer)
    
43. {
    
44.         while(1)
    
45.         {
    
46.                 while(((in+1)%BUFFER_SIZE) == out)/* buffer is full */
    
47.                         ;
    
48.                 scanf("%d",&nextProduced);
    
49.                 buffer[in] = nextProduced;
    
50.                 in = (in+1)%BUFFER_SIZE;
    
51.         }
    
52.         return ;
    
53. }
    
54. 
    
55. void thread_consumer(int* buffer,FILE *fout)
    
56. {
    
57.         while(1)
    
58.         {
    
59.                        /*buffer is empty*/
    
60.                 while(in == out)
    
61.                         ;
    
62.                 nextConsumed = buffer[out];
    
63.                 fprintf(fout,"%d\n",nextConsumed);
    
64.                 out = (out+1)%BUFFER_SIZE;
    
65.         }
    
66.         return ;
    
67. }
    

复制代码

刚开始学操作系统，试着写了点，上来就错了阿。。誰来帮帮我阿。

myworkstation

回复 1# 373202184


    数据对步在哪里？nextConsumed，nextProduced，in,out在两个线程里同时访问，而且还同步访问终端，不进行同步当然问题多多。

folklore

1. 文件写和读， Offset已经变了。
2. 要同步。

井蛙夏虫

回复 1# 373202184
全局变量buffer，函数形参buffer
main局部变量fout，函数形参fout
pthread_create最后一个参数都为NULL


   

373202184

两个线程不是共享主代码段的数据么？Producer 写如数据后才可以让Consumer读取然后写入文件呀。
while(in == out)  /*Buffer 已经空了,Consumer一直在等待阿。*/
       ;
回复 2# myworkstation


   

373202184

回复 4# 井蛙夏虫

额，这样有什么问题么？


   

373202184

回复 3# folklore
麻烦详细解释一下可否