记录进程启动的日志

Author: ueaner

src/Process.php

@@ -45,11 +45,15 @@ public function start()
         $this->masterPid = posix_getpid();
         $this->setProcName();
 
+        $this->log("\"{$this->name}\" started");
+
         for ($id = 1; $id <= $this->count; $id++) {
             $this->forkWorker($id);
         }
 
         $this->waitAll();
+
+        $this->log("\"{$this->name}\" stopped");
     }
 
     protected function forkWorker($id)
@@ -65,8 +69,6 @@ protected function forkWorker($id)
 
             $this->setProcName();
 
-            register_shutdown_function([$this, 'handleShutdown']);
-
             // Run worker.
             $this->run();
             exit(0);
@@ -134,7 +136,7 @@ protected function waitAll()
                 if ($id === false) {
                     continue;
                 }
-                $this->log("[worker:$id $pid] exited with status $status");
+                $this->log("[worker:$id $pid] process stopped with status $status");
                 unset(static::$workers[$id]);
 
                 // refork
@@ -143,8 +145,6 @@ protected function waitAll()
                 }
             }
         }
-
-        $this->log("\"{$this->name}\" stopped");
     }
 
     protected function setProcName()
@@ -160,7 +160,10 @@ protected function setProcName()
 
     protected function run()
     {
+        register_shutdown_function([$this, 'handleShutdown']);
+
         try {
+            $this->log("[worker:{$this->id} {$this->workerPid}] process started");
             // Run job.
             call_user_func($this->job, $this);
         } catch (\Throwable $e) {