Linux 多线程文件读写操作 +实例

winston

邮箱通讯

声明以下全局变量
char cBuff[256];   //邮箱
int iHead;        //邮箱头指针
int iTail;        //邮箱尾指针

创建两个线程：XXX_Write和XXX_Read。
XXX_Write：读取一个文件（大点的），将文件内容按序写入邮箱，同时修改尾指针。即头尾指针之间的内容是提供给XXX_Read线程读取的。
XXX_Read：从邮箱中读取未读的数据，写入一个新文件，同时修改头指针。

2. #include <stdio.h>
3. #include <pthread.h>
4. #include <stdlib.h>
5. #include <sys/types.h>
6. #include <sys/stat.h>
7. #include <fcntl.h>
8. #include <unistd.h>
11. #define MAX 256     /* 邮箱大小*/
12. #define SIZE 64                /*每次读取大小*/
14. char cBuff[MAX];
15. int iHead;
16. int iTail;
18. int xxx_write(const char *w_path)
19. {
21.         FILE *w_fp;       
22.         int sizen;          /*实际读取大小*/
23.         int i;
25.         if(NULL == (w_fp= fopen(w_path , "r+")))  /*打开一个要读取数据的文件*/
26.         {
27.                         printf("error: Can not open %s .\n",w_path);
28.                        
29.                         pthread_exit((void *)1);
30.         }
31.        
33.         while(1)
34.         {
35.                 if(iTail != (iHead + 1))   /*判断邮箱是否为空*/
36.                 {
37.                         continue ;
38.                 }
39.                
40.                 if((MAX - iTail) < SIZE)
41.                 {
42.                         iTail = 0;
43.                         iHead = -1;
44.                 }
45.                
46.                 if((sizen = fread(cBuff+iTail,1,SIZE,w_fp)) == 0)  /*读出数据并写入邮箱?/
47.                 {
48.                                 fclose(w_fp);
49.                        
50.                                 pthread_exit((void *)2);
51.                 }
52.        
53.                 iTail += sizen; /*移动尾指针*/
54.                                
55.         }
56.        
57.        
58. }
62. int xxx_read(const char *r_path)
63. {
64.         FILE *fp;
65.         int i,j;
66.        
67.         if(NULL == (fp = fopen(r_path , "at+")))
68.         {
69.                         printf("error: Can not open %s.\n",r_path);
70.                        
71.                         pthread_exit((void *)1);
72.         }
73.                
74.         pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,NULL);       
75.        
76.         while(1)
77.         {
78.                 if((iHead + 1) == iTail) /* 判读邮箱中是否有数据*/
79.                 {
80.                         continue ;
81.                 }
82.        
83.        
84.                 if(fwrite(cBuff+iHead+1,1, (iTail - iHead ),fp) < 0) /*读出数据并写入另一个文件*/
85.                 {
86.                         fclose(fp);
87.                        
88.                         pthread_exit((void *)2);
89.                 }
90.                
92.                 iHead = iTail - 1  ;  /*移动头指针/
93.                
94.         }
95. }
98. int main(int argc , char *argv[])
99. {
100.         int *value_ptr;
101.             pthread_t wtid,rtid;
102.        
103.         iHead = MAX - 1; /*初始化头尾指针*/
104.         iTail = 0;
106.         if(argc != 3)
107.         {
108.                         printf("error:please input two files name.\n");
109.                         return -1;
110.         }
111.        
112.         if(pthread_create(&wtid,NULL,(void *)xxx_write,argv[1]) != 0)
113.         {
114.                         printf("error: Can not create xxx_write.\n");
115.                         return -2;
116.         }
117.        
119.         if(pthread_create(&rtid,NULL,(void *)xxx_read,argv[2]) != 0)
120.         {
121.                         printf("error: Can not create xxx_read.\n");
122.                         return -2;
123.         }
125.         pthread_join(wtid,(void **)&value_ptr); /*等待读线程结束*/
126.        
127.         pthread_cancel(rtid);
129.         printf(" over \n");
130.        
131.        
132.         return 0;
133. }

复制代码

作者：jmq_0000 发表于2012-2-24 12:56:28 原文链接