unix下多进程实现问题

ldalei

具体情况是这样的：先写了一个对文本进行处理的动态链接库，然后编写一个程序调用此动态连接库里的函数对文本进行处理，为了达到cpu处理的极限，便希望以多个进程来分别调用此函数，然后对不同的文本进行处理。
由于本人较笨，只好这样来编写程序，用多个if(fork()==0){....}else{if (fork==0){...}else...}这样来处理，最后调用wait()函数等待进程结束。但是wait()函数是等待最快结束的一个子进程，并不是等待所有进程结束。所以导致了最后的结果很怪异。
请问一下如何来解决等待所有子进程结束然后在开始运行父进程的下步程序。另外有没有什么其他办法来解决多进程调用函数运行（不要象我上面的那么的傻）。
希望赐教，先多谢了～

FH

记住子进程的个数，必要时再记住各个PID，循环wait就行了。

mq110

>;>;但是wait()函数是等待最快结束的一个子进程，并不是等待所有进程结束。所以导致了最后的结果很怪异。


处理SIGCHLD信号.用waitpid 可以等待这个组的所有子进程

sunlan

发一个我以前写的程序，在生产上用的，看对你有没有帮助

1. 
   
2. 
   
3. void main( int argc, char **argv )
   
4. {
   
5. EXEC SQL BEGIN DECLARE SECTION;
   
6. long pid, secuid;
   
7. EXEC SQL END DECLARE SECTION;
   
8.         int ret, i, p_stat;
   
9.         char profile[FILENAME_MAX], tmp[40];
   
10.         struct Process *proc;
    
11. 
    
12.         if( (proc=GetProcess( (char *)getenv("LOGNAME"), argv[0], &i))
    
13.                 !=(struct Process *)NULL && i>;1 )
    
14.         {
    
15.                 printf( "Other process %s is running!\n", argv[0] );
    
16.                 while( i>;0 ){
    
17.                         if( proc[i-1].pid!=getpid() )
    
18.                                 printf( "pid=[%d]\n", proc[i-1].pid );
    
19.                         i--;
    
20.                 }
    
21.                 exit( -1 );
    
22.         }
    
23. 
    
24.         if( argc>;=2 && atoi(argv[1])!=0 )
    
25.                 t_interval=atoi( argv[1] );
    
26.         else {
    
27.                 sprintf( profile, "%s/etc/%s", (char *)getenv("HOME"), PROFILE );
    
28.                 if( GetProfileString( profile, "LOCALE INFO",
    
29.                         "reverse_interval", tmp )==0 )
    
30.                 {
    
31.                         t_interval=atoi(tmp);
    
32.                 } else
    
33.                         t_interval=30;
    
34.         }
    
35. 
    
36.         signal(SIGINT,SIG_IGN);
    
37.         signal(SIGPIPE,SIG_IGN);
    
38.         signal(SIGQUIT,SIG_IGN);
    
39. 
    
40.         if (( pid=fork() )<0) {
    
41.                 printf("REVERSE SERVER START FAILED!!!\n");
    
42.                 exit(-1);
    
43.         } else if (pid>;0 )
    
44.                 exit(0);
    
45. 
    
46.         if(setpgrp()<0) {
    
47.                 printf("CHANGE GROUP ERROR!!!\n");
    
48.                 fflush(stdout);
    
49.                 exit(-1);
    
50.         }
    
51.         signal(SIGHUP,SIG_IGN);
    
52.         signal(SIGTERM,EXIT);
    
53. 
    
54.         EXEC SQL database secudb;
    
55.         if( SQLCODE!=0 ){
    
56.                 printf( "OPEN DATABASE ERROR[%d]! EXIT\n", SQLCODE );
    
57.                 exit( -1 );
    
58.         }
    
59. 
    
60.         EXEC SQL declare revcur cursor for
    
61.                 select unique(secuid) from reverse
    
62.                 where trans_date=today
    
63.                 and result NOT in ( "11", "10", "01" );
    
64.         if( SQLCODE!=0 ){
    
65.                 printf( "DATABASE ERROR[%d]! EXIT\n", SQLCODE );
    
66.                 exit( -1 );
    
67.         }
    
68. 
    
69.         printf("AUTO REVERSE SERVER START OK!!!\n");
    
70.         fflush(stdout);
    
71. 
    
72.         while( 1 ) {
    
73.                 sleep( t_interval );
    
74. 
    
75.                 EXEC SQL open revcur;
    
76.                 if( SQLCODE!=0 ) {
    
77.                         SDKerrlog( REVERSELOG, "%s|%d| open cursor error[%d]",
    
78.                                 __FILE__, __LINE__, SQLCODE );
    
79.                         continue;
    
80.                 }
    
81.                 p_head=(struct rev_t*)NULL;
    
82.                 p=p_head;
    
83.                 p_prev=NULL;
    
84.                 p_next=NULL;
    
85.                 i=0;
    
86.                 while( 1 ) {
    
87.                         EXEC SQL fetch revcur into :secuid;
    
88.                         if( SQLCODE!=0 ){
    
89.                                 if( SQLCODE==100 ) {
    
90.                                         EXEC SQL close revcur;
    
91.                                         break;
    
92.                                 } else {
    
93.                                         SDKerrlog( REVERSELOG, "%s|%d| fetch \
    
94. next error[%d]", __FILE__, __LINE__, SQLCODE );
    
95.                                         EXEC SQL close revcur;
    
96.                                         break;
    
97.                                 }
    
98.                         }
    
99. 
    
100.                         if( (pid=fork())<0 ) {
     
101.                                 SDKerrlog( REVERSELOG, "%s|%d| Create new process \
     
102. error[%s] secuid[%d]", __FILE__, __LINE__, strerror(errno), secuid );
     
103.                                 continue;
     
104.                         }
     
105. 
     
106.                         if( pid>;0 ) { /* main process */
     
107.                                 if( RegistProc( pid, secuid )<0 ){
     
108.                                         SDKerrlog( REVERSELOG, "%s|%d| regist \
     
109. process[%d] secuid[%d] error", __FILE__, __LINE__, pid, secuid );
     
110.                                         continue;
     
111.                                 }
     
112.                                         i++;
     
113.                         } else {/* sub process */
     
114.                                 SubReverse( secuid );
     
115.                                 exit( 1 );
     
116.                         }
     
117.                 }
     
118. 
     
119. SDKerrlog( REVERSELOG, "%s|%d| Total [%d] reverse process. MainProcess[%d]",
     
120.         __FILE__, __LINE__, i, getpid() );
     
121. 
     
122.                 while( i>;0 ) {
     
123.                         if( (pid=wait( &p_stat ))<0 ) {
     
124.                                 SDKerrlog( REVERSELOG, "%s|%d| wait error[%s]",
     
125.                                         __FILE__, __LINE__, strerror(errno) );
     
126.                                 continue;
     
127.                         }
     
128.                         SDKerrlog( REVERSELOG, "%s|%d| process[%d] finished",
     
129.                                 __FILE__, __LINE__, pid );
     
130.                         if( ReleRevProc( pid )<0 )
     
131.                                 continue;
     
132.                         i--;
     
133.                 }
     
134. 
     
135.                 ReleRevTbl();
     
136.         }
     
137. }
     
138. 
     

复制代码

里面有些自定义函数，可以忽略

galaxywar

处理SIGCHLD信号,信号处理程序里用WNOHANG的方式循环waitpid,PID参数用-1