From 14eb4c0009d18895d776b030a38d1870a7449ca2 Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Mon, 1 Mar 2021 01:00:06 +0800
Subject: [PATCH] modify

---
 HttpServer/Events/OnManagerStart.php | 32 +++++++++++++++++-----------
 1 file changed, 19 insertions(+), 13 deletions(-)

diff --git a/HttpServer/Events/OnManagerStart.php b/HttpServer/Events/OnManagerStart.php
index f4a9acf0..049874aa 100644
--- a/HttpServer/Events/OnManagerStart.php
+++ b/HttpServer/Events/OnManagerStart.php
@@ -45,7 +45,7 @@ class OnManagerStart extends Callback
         }
         name(Config::get('id', false, 'system') . ' Server Manager.');
 
-        Coroutine\go([$this, 'onSignal'], $server);
+        Process::signal($this->signal, [$this, 'onSignal']);
     }
 
 
@@ -53,20 +53,26 @@ class OnManagerStart extends Callback
      * @param $server
      * @param $worker_id
      */
-    public function onSignal($server)
+    public function onSignal()
     {
-        $receive = Coroutine::waitSignal($this->signal, 30);
-        while ($receive === true) {
-            if ($this->isPrint === false) {
-                $this->warning(sprintf('Receive Worker stop event.'));
-                $this->isPrint = true;
-            }
-            if (!Snowflake::app()->isRun()) {
-                break;
-            }
-            sleep(1);
+        while ($ret = Process::wait(false)) {
+            echo "PID={$ret['pid']}\n";
         }
-        return $server->stop();
+
+
+//
+//        $receive = Coroutine::waitSignal($this->signal, 30);
+//        while ($receive === true) {
+//            if ($this->isPrint === false) {
+//                $this->warning(sprintf('Receive Worker stop event.'));
+//                $this->isPrint = true;
+//            }
+//            if (!Snowflake::app()->isRun()) {
+//                break;
+//            }
+//            sleep(1);
+//        }
+//        return $server->stop();
     }
 
 }