#! perl -slw
use strict;
use Time::HiRes qw[ sleep time ];
use threads;
use threads::shared;

my @pids :shared;

sub asyncPipedProc {
    my $tid = threads->tid;
    my $cmd = shift;
    $pids[ $tid ] = open my $pipe, '-|', $cmd or die $!;
    my @input;
    push @input, $_ while <$pipe>;
    return @input;
}

my $cmd = q[ perl -E"$|++; sleep(1), say for 1 .. 5" ];

my @running;
for my $timeout ( 3 .. 7 ) {
    push @running, [
        threads->new( \&asyncPipedProc, $cmd, $_ ),
        time() + $timeout
    ];
}

while( @running and sleep 0.1 ) {
    for my $i ( reverse 0 .. $#running ) {
        if( $running[ $i ][ 1 ] < time() ) {
            kill 2, $pids[ $running[ $i ][ 0 ]->tid ];
            printf "From thread %d got:\n%s",
                $running[ $i ][ 0 ]->tid,
                join'', $running[ $i ][ 0 ]->join;
            splice @running, $i, 1;
        }
    }
}
__END__
C:\test>multi-timeout.pl
Terminating on signal SIGINT(2)
From thread 1 got:
1
2
3
Terminating on signal SIGINT(2)
From thread 2 got:
1
2
3
4
From thread 3 got:
1
2
3
4
5
From thread 4 got:
1
2
3
4
5
From thread 5 got:
1
2
3
4
5