多进程文件操作

cokeboL

get_fp没细看。是想在每个子进程中写文件然后再关闭吗？您的while放在pid==0，就是else后面的{}里吧，现在这么写是父子进程都执行while里的，所以乱了。

cokeboL

回复  gamblegod


    我这个例子是没举好。实际情况是这样的情况下，多个子进程都在同一时间创建了文 ...
sumland 发表于 2011-06-24 14:58

按我上个回复的那么改，while放在pid==0的里面就ok了。只差一个花括号的位置。我试了，ok

1. #include<stdio.h>
   
2. #include<stdlib.h>
   
3. #include<string.h>
   
4. #include<unistd.h>
   
5. #include<sys/types.h>
   
6. #include<time.h>
   
7. //这个程序的目的在于实现每隔一段时间就开一个文件，并对其写入，还要保证之前被关闭的文件不再有新的写入
   
8. 
   
9. typedef struct myfp_info
   
10. {
    
11.         FILE *nfp;
    
12.         time_t ncreat_time;
    
13. }MYFP_INFO;
    
14. 
    
15. int get_fp(MYFP_INFO *NowFp,char *sw)
    
16. {
    
17. time_t NowTime=time(NULL);
    
18. 
    
19. 
    
20. if((NowTime-NowFp->ncreat_time)>=10)
    
21.         {
    
22.                 printf(" time up\n");
    
23.                 fclose(NowFp->nfp);
    
24.                 char namefile[128];
    
25.                 memset(namefile,0x0,128);
    
26.                 sprintf(namefile,"/opt/strtmp%d",NowTime);
    
27.                 NowFp->nfp=fopen(namefile,"w+");               
    
28.                 fwrite(sw,1,strlen(sw),NowFp->nfp);
    
29.                 char str[]="\n\n";
    
30.                 fwrite(str,1,strlen(str),NowFp->nfp);
    
31.                 NowFp->ncreat_time=NowTime;         
    
32.                 printf("ncreat_time1 =%d\n",NowFp->ncreat_time);
    
33.         }  
    
34. else{
    
35.         printf("write string:<%s>,len<%d>\n",sw,strlen(sw));
    
36.         fwrite(sw,1,strlen(sw),NowFp->nfp);
    
37.         char str[]="\n";
    
38.         fwrite(str,1,strlen(str),NowFp->nfp);
    
39. 
    
40.         }
    
41.         
    
42. return 0;                        
    
43. }
    
44. 
    
45. MYFP_INFO NowFp; //全局变量
    
46. 
    
47. int main()
    
48. {
    
49. int i=0;
    
50. time_t NowTime=time(NULL);
    
51. char str[]="sunstring\n";
    
52. NowFp.ncreat_time=NowTime;
    
53. char namefile[128];
    
54. memset(namefile,0x0,128);
    
55. sprintf(namefile,"/opt/strtmp%d",NowTime);
    
56. NowFp.nfp=fopen(namefile,"w+");
    
57.         
    
58. pid_t pid;
    
59. pid=fork();
    
60. 
    
61. if(pid<0)
    
62.         {
    
63.         printf("fork faild!\n");
    
64.         exit(1);
    
65.         }
    
66. else if(pid>0)
    
67.         {
    
68.         printf("this is parrent process!child process id is:%ld\n",pid);
    
69.         
    
70.         }
    
71. else {
    
72.         printf("this is child process!\n");               
    
73. //} 此处原来的{去掉放下面while之后把while包进来           
    
74.         
    
75.         while(i<120)
    
76.                 {
    
77.                 i++;
    
78.                 sleep(1);
    
79.                 get_fp(&NowFp,str);
    
80.                 }
    
81. }  //就是放在这里     
    
82. return 1;
    
83. }

复制代码

cokeboL

我更正一下问题：就是fork了多次。
sumland 发表于 2011-06-24 15:48

不想fork多次，那就把fork()去掉或者fork()一次但执行循环多多次。
如果需要子进程执行其他任务，那就保留fork()，在父进程中写文件。
楼主你的问题表述的让人分析起来好累，咱能一次性多说几句不。。。或者把代码多贴点，这又不算啥值钱东西

cokeboL

难道是想把fork()放到get_fp里？

cokeboL

回复 10# sumland

1. while(1)
   
2. 
   
3. {        
   
4. ...//略去        
   
5.         pid_t pid;
   
6.   pid=fork();
   
7.   if(pid<0)
   
8.         {
   
9.         close(nConnectSocket);
   
10.                                 continue;
    
11.         }
    
12.         else if(pid>0)
    
13.         {
    
14.               close(nConnectSocket);   
    
15.                                 continue;      
    
16.         while(i<120)
    
17.                 {
    
18.                 i++;
    
19.                 sleep(1);
    
20.                 get_fp(&NowFp,str);
    
21.                 }        
    
22.         }                           
    
23. }
    
24. 
    

复制代码

pid判断那块是不是少了else（pid == 0 )的情况？否则这逻辑不对啊，while里的那个while能执行到吗？不是continue了吗？
如果是少了的话，看这段代码，楼主fork()的子进程做的事情应该是继承了第一次循环之后的代码，然后子进程fork()的子进程也是，如此循环，会又子子孙孙循环fork()和get_fp的情况吧？那自然就有很多个进程在比较自己的nowtime和creattime满足>=10的时候创建文件了。也就是说这个fork()创建的子进程除了对程序破坏并没有进行有意义的活动。干脆把fork()去掉算了，就要达到的目的来说，没必要用多进程的感觉，楼主试试。如果非要多进程，那试试

1. while(1)
   
2. 
   
3. {        
   
4. ...//略去        
   
5.         pid_t pid;
   
6.   pid=fork();
   
7.   if(pid<0)
   
8.         {
   
9.         close(nConnectSocket);
   
10.                                 continue;
    
11.         }
    
12.         else if(pid>0)
    
13.         {
    
14.                close(nConnectSocket);   
    
15.                                 continue;   
    
16.        }
    
17.        else{
    
18.         while(i<120)
    
19.                 {
    
20.                 i++;
    
21.                 sleep(1);
    
22.                 get_fp(&NowFp,str);
    
23.                 }        
    
24.         }                     
    
25. }
    

复制代码

cokeboL

回复 12# sumland


    我截的就是你10楼的，也是照10楼改的，你仔细看下哈

cokeboL

回复 12# sumland


    我在11楼的回复，两段代码，上段是你10楼里的，下段是改的，中间是分析的，楼主试下按改过的能实现不

cokeboL

不好意思，我一直没讲明白，我的目的是在子进程里执行那个get_fp，还是要保证get_fp执行完一次之后才再执行 ...
sumland 发表于 2011-06-27 09:25

我很郁闷，我改的就是在子进程里执行get_fp（）；而且根据你前面get_fp（）的代码，应该是子进程执行它但根据时间间隔来判断是否新建文件，而不是你说的“我的目的是在子进程里执行那个get_fp，还是要保证get_fp执行完一次之后才再执行 ...”，否则你get_fp（）的代码就可以裁掉一些。如果是要“保证get_fp执行完一次之后才再执行”，时间间隔的判断就该挪到外边或者添加其他flag对多进程间进行同步。你对文件写入的操作没说清楚，个人感觉get_fp（）的实现和你的要求之间有些矛盾。

给点建议撒：

1. 1.请尽量理清自己要问的问题；
   
2.             
   
3. 2.别人的认真的回复也请仔细看下，否则，假如你对多进程不熟悉，别人给你改了，你都不看，你还是按自己原来可能是错误的只是来理解，那别人怎么弄都无法达到  你要求；
   
4.             
   
5. 3.另外，回帖子请点回复或引用撒，否则系统没有提示，别人再浏览这帖子才能发现你回复了。
   
6. 
   
7. 4.如果回帖对你没用，可以直接无视。

复制代码

好吧，我放弃了。

cokeboL

回复 17# sumland


原因我已经回复过了，你不看。。。你对fork的基本用法都不太懂，pid == 0 和 > 0 你仔细考虑过吗？子进程继承了什么，从什么地方开始继承你都弄明白了吗？ 不懂又不看回复，或者看了又不去思考和弄明白你不懂的地方，那怎么搞？又不是在一起工作，谁能一个字一个字把书上东西都敲给你啊。。。

cokeboL

回复  cokeboL


    谢谢回复！我只希望通过问问题能得到些启发，比如你说的进程同步，我还是想弄清楚 ...
sumland 发表于 2011-06-27 12:15

父子进程，举个例子吧：

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <unistd.h>
   
4. 
   
5. int main()
   
6. {
   
7.     pid_t pid;
   
8. 
   
9.     while(1){
   
10.         pid=fork();
    
11.         if( pid < 0 )
    
12.             perror("fork"), exit(-1);
    
13.         else if( pid > 0 )
    
14.             exit(0);
    
15.         else if( pid == 0 ){
    
16.             printf("child\n");
    
17.             sleep(1);
    
18.         }
    
19.     }
    
20. }
    

复制代码

你猜一下执行结果打印几次child，然后执行一下，为什么这样？