Changeset 8876 for lang/perl/Parallel-Prefork/trunk/lib/Parallel/Prefork.pm

Timestamp:

04/04/08 17:44:49 (5 years ago)

Author:

kazuho

Message:

don't delay if worker process was killed by parent

Files:

• lang/perl/Parallel-Prefork/trunk/lib/Parallel/Prefork.pm (modified) (3 diffs)

lang/perl/Parallel-Prefork/trunk/lib/Parallel/Prefork.pm

@@ -24 +24 @@
         signal_received      => '',
         manager_pid          => undef,
+        generation           => 0,
         %$opts,
     }, $klass;
@@ -37 +38 @@
     $self->manager_pid($$);
     $self->signal_received('');
+    $self->{generation}++;
     
     die 'cannot start another process while you are in child process'
@@ -57 +59 @@
                 return;
             }
-            $self->{worker_pids}{$pid} = 1;
+            $self->{worker_pids}{$pid} = $self->{generation};
         }
         if (my ($exit_pid, $status) = wait3(! $pid)) {
-            delete $self->{worker_pids}{$exit_pid};
-            unless ($status == 0) {
+            if (delete($self->{worker_pids}{$exit_pid}) == $self->{generation}
+                    && $status != 0) {
                 sleep $self->err_respawn_interval;
             }