[ новости /+++ | форум | теги | ]

Каталог документации / Раздел "Perl" (Архив | Для печати)

Межпроцессовые взаимодействия на Perl

Процессы и с чем их едят

fork;

unless defined(fork) { print "обработайте ошибку, или вместо этого вызовите die" }

#!/usr/bin/perl -w
# fork.pldie "Non-flying weather"
 unless defined(fork);
print "I'm number $$\n";
В результате выполнения вы увидете что-то вроде[root@avalon tests]
# ./fork.pl
I'm number 6773
I'm number 6774

Фильтрация выходных данных

#!/usr/bin/perl -w
# nfilter.plfilter();
for ($I = 0; $I < 20; $I +){
 print "Output line\n";
 }
sub filter{
die "Cannot fork"
 unless defined($fpid = open(STDOUT,"-"));
      return if ($fpid != 0);
      num = 0;
      while (<>) {
 print "$num:\t$_";
 $num ++;
 }
      exit;
}

open(HANDLE, " $cmd"); # направить информацию на вход программы

      while (<>) { print "$num:\t$_"; $num ++; }
Вот так то, берем и правим

#!/usr/bin/perl -w
# nfilter.plfilter();
for ($I = 0; $I < 20; $I +){
 print "Output line\n";
 }close(STDOUT);
sub filter{
die "Cannot fork"
 unless defined($fpid = open(STDOUT,"-"));
      return if ($fpid != 0);
      num = 0;
      while (<>) {
 print "$num:\t$_";
 $num ++;
 }
      exit;
}

#!/usr/bin/perl -w
# errfilter.plmy ($fpid,$oldout);
pipe(FOR_READ,FOR_WRITE);
select((select(FOR_READ),$ = 1)[0]);
select((select(FOR_WRITE),$ = 1)[0]);
start_filter();
for ($I = 0; $I < 20; $I +){
 print "Output line\n";
 }
# Error("bug");
close(FOR_WRITE);
waitpid($fpid,0);
sub start_filter{
      die "Cannot fork"
 unless defined($fpid = fork);
unless ($fpid == 0){
      close(FOR_READ);
      $oldout = select(FOR_WRITE);
      return;
}
      close(FOR_WRITE);
      my ($out,$num) = ("",0);
      while() {
 $out .= "$num\t$_"; $num ++;
 }
close(FOR_READ);
print $out;
exit;
}
sub Error{
      my ($error_text) = @_;
select($oldout);
kill KILL => $fpid;
close(FOR_WRITE);
print "Error: $error_text\n";
exit;
}

Партнёры:

Хостинг: