1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
|
#
# (c) Jan Gehring <jan.gehring@gmail.com>
#
package Rex::Fork::Task;
use v5.14.4;
use warnings;
use POSIX ":sys_wait_h";
our $VERSION = '1.16.1'; # VERSION
sub new {
my $that = shift;
my $proto = ref($that) || $that;
my $self = {@_};
bless( $self, $proto );
$self->{'running'} = 0;
return $self;
}
sub start {
my ($self) = @_;
$self->{'running'} = 1;
$self->{pid} = fork;
if ( !$self->{pid} ) {
$self->{coderef}->($self);
$self->{'running'} = 0;
exit();
}
}
sub wait {
my ($self) = @_;
my $rpid = waitpid( $self->{pid}, &WNOHANG );
if ( $rpid == -1 ) { $self->{'running'} = 0; }
return $rpid;
}
1;
|
