# License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
# Limits the number of processes spawned
# License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
# Limits the number of processes spawned
if (delete $self->{rpipe}) {
my $pid = delete $self->{pid};
$self->{err} = $pid == waitpid($pid, 0) ? $? :
"PID:$pid still running?";
if (delete $self->{rpipe}) {
my $pid = delete $self->{pid};
$self->{err} = $pid == waitpid($pid, 0) ? $? :
"PID:$pid still running?";
- if (my $next = shift @{$limiter->{run_queue}}) {
- _do_spawn(@$next);
+
+ # limiter->{max} may change dynamically
+ if (($running || $limiter->{running}) < $limiter->{max}) {
+ if (my $next = shift @{$limiter->{run_queue}}) {
+ _do_spawn(@$next);
+ }
my ($self, $limiter, $cb) = @_;
$self->{limiter} = $limiter;
my ($self, $limiter, $cb) = @_;
$self->{limiter} = $limiter;