兩個線程實現(xiàn)文件寫入，編譯通過，可是提示段錯誤郁悶

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. }
    

復制代碼

剛開始學操作系統(tǒng)，試著寫了點，上來就錯了阿。。誰來幫幫我阿。

myworkstation

回復 1# 373202184


    數(shù)據(jù)對步在哪里？nextConsumed，nextProduced，in,out在兩個線程里同時訪問，而且還同步訪問終端，不進行同步當然問題多多。

folklore

1. 文件寫和讀， Offset已經(jīng)變了。
2. 要同步。

井蛙夏蟲

回復 1# 373202184
全局變量buffer，函數(shù)形參buffer
main局部變量fout，函數(shù)形參fout
pthread_create最后一個參數(shù)都為NULL


   

373202184

兩個線程不是共享主代碼段的數(shù)據(jù)么？Producer 寫如數(shù)據(jù)后才可以讓Consumer讀取然后寫入文件呀。
while(in == out)  /*Buffer 已經(jīng)空了,Consumer一直在等待阿。*/
       ;
回復 2# myworkstation


   

373202184

回復 4# 井蛙夏蟲

額，這樣有什么問題么？


   

373202184

回復 3# folklore
麻煩詳細解釋一下可否