记录 worker id 到日志文件

Author: ueaner

src/Process.php

@@ -126,7 +126,7 @@ protected function waitAll()
                 if ($id !== false) {
                     unset(static::$workers[$id]);
                 }
-                $this->log("[worker $pid] exited with status $status");
+                $this->log("[worker.$id $pid] exited with status $status");
             }
         }
 
@@ -150,15 +150,15 @@ protected function run()
             // Run job.
             call_user_func($this->job, $this);
         } catch (\Throwable $e) {
-            $this->log('[worker '. posix_getpid() .'] ' . $e);
+            $this->log("[worker.{$this->id} {$this->workerPid}] " . $e);
             // rerun
             $this->run();
         }
     }
 
     public function handleShutdown()
     {
-        $errmsg = '[worker '. posix_getpid() .'] process terminated';
+        $errmsg = "[worker.{$this->id} {$this->workerPid}] process terminated";
         // Handle last error.
         $error = error_get_last();
         if ($error) {
@@ -223,7 +223,7 @@ public function signalShutdownHandler($signo)
                 unset(static::$workers[$id]);
             }
         } else {
-            $this->log('[worker '. posix_getpid() .'] ' . $msg);
+            $this->log("[worker.{$this->id} {$this->workerPid}] " . $msg);
 
             // Worker process exit.
             exit(0);