Un pipe con etapas

El ejemplo anterior puede generalizarse a un número arbitrario de etapas. En este ejemplo el proceso padre crea sucesivamente hijos mediante open(STDOUT, "|-") reconectando su STDOUT al STDIN del último hijo creado. Como el hijo hereda el STDOUT del padre en su estado previo a la redirección, tenemos que,

La primera vez el STDOUT del hijo será el STDOUT original (asociado con la terminal)
En las veces subsiguientes el STDOUT del hijo es el STDOUT anterior del padre, el cual estaba ya conectado al STDIN del hijo creado en la iteración anterior.

lhp@nereida:~/Lperl/src/cookbook/ch16$ cat -n pipes.pl
 1  #!/usr/bin/perl -w
 2  $| = 1;
 3  use strict;
 4  my $NP = shift || 4;
 5  my $LAST = $NP-1;
 6  my @pid;
 7  $| = 1;
 8
 9  $pid[0] = $$;
10  create_child($NP-$_) for 1..$LAST;
11
12  task(0);
13
14  wait for 1..$LAST;
15  exit;
16
17  sub create_child {
18    my $id = shift;
19
20    return if $pid[$id] = open(STDOUT, "|-");
21    die "Cannot fork $!" unless defined $pid[$id];
22
23    task($id); # do something
24
25    exit;
26  }
27
28  sub task {
29    my $id = shift;
30
31    my $num = $id? <STDIN> : 0;
32
33    $num += $id;
34    $num .= "\n"; # flush
35
36    syswrite STDOUT, $num;
37  }

Al ejecutar tenemos:

lhp@nereida:~/Lperl/src/cookbook/ch16$ pipes.pl 8
28
lhp@nereida:~/Lperl/src/cookbook/ch16$ pipes.pl 7
21
lhp@nereida:~/Lperl/src/cookbook/ch16$ pipes.pl 6
15
lhp@nereida:~/Lperl/src/cookbook/ch16$ pipes.pl 5
10