进程间通信问题!!!求解~~~

klathleen

描述:
fork 之后.. 父进程检查状态..while循环等待子进程的状态...子进程则进行 mysqldump备份数据库...子进程备份完成后 将system 返回值通过管道发给父进程..父进程读句柄得到后 则判断返回值..

部分代码:

1.        pipe(PARENT_READ,CHILD_WRITE);  
   
2.                 if(my $pid = fork) {
   
3.                         close(CHILD_WRITE);
   
4.                         my $child_return;
   
5.                         print "db_connect(...,...,...,...)\n";
   
6.                         print "Parent:$\n";
   
7. 
   
8.                         while(!sysread(PARENT_READ,$child_return,10)) {   //循环等待子进程,子进程无通知则进入循环.. 问题也就出现在这...父进程一直等待子进程..阻塞...
   
9.                                 print "checking...\n";
   
10.                                 sleep(5);
    
11.                         }   
    
12. 
    
13.                         print "db_con->disconnect!\n";
    
14.                         $back_status = $child_return;
    
15.                         print $back_status."\n";
    
16.                 }else {
    
17.                         if(!defined $pid) {
    
18.                                 print "**Error: can't fork.\n";
    
19.                                 print " EXEC Mail_Send function....\n";
    
20.                         }   
    
21.                         print "CHild:$\n";   
    
22.                         close(PARENT_READ);
    
23.                         $back_status = system("mysqldump -u root -p'taofang' test t > /tmp/t.sql");
    
24.                         sleep(10);
    
25.                         print CHILD_WRITE $back_status;
    
26.                         exit(0);   
    
27.                 }   

复制代码

erpeng_1988

db_connect(...,...,...,...)
Parent:
CHild:
db_con->disconnect!
0
我的RHEL6.3 可以出来结果。也有/tmp/t.sql产生。不过有个疑问是sysread读不到的话不会阻塞，应该立即返回。但为什么没有打印checking...呢

klathleen

回复 2# erpeng_1988


    这也是我的疑问... 当子进程没有通信时也就是sysread 没读到东西时...父进程会阻塞...我想要的是不阻塞..进入下面的checking代码..要不然的话 这个fork 也就没意义了...

erpeng_1988

回复 3# klathleen
use Fcntl qw(F_GETFL F_SETFL O_NONBLOCK);
 $flags = fcntl(REMOTE, F_GETFL, 0)
                               or die "Can’t get flags for the socket: $!\n";
 $flags = fcntl(REMOTE, F_SETFL, $flags │ O_NONBLOCK)
                               or die "Can’t set flags for the socket: $!\n";
可以拿fcntl指定不阻塞，结果如下：
db_connect(...,...,...,...)
Parent:
checking...
CHild:
checking...
checking...
db_con->disconnect!
0 

   

klathleen

回复 4# erpeng_1988


    已解决..谢了....