From 2ac21328f680ef25a1cc1ffad91db494860e82c0 Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Sun, 28 Feb 2021 00:31:07 +0800
Subject: [PATCH] modify

---
 HttpServer/Events/OnWorkerStart.php | 20 ++++++++------------
 1 file changed, 8 insertions(+), 12 deletions(-)

diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php
index bafd90e6..875e6f95 100644
--- a/HttpServer/Events/OnWorkerStart.php
+++ b/HttpServer/Events/OnWorkerStart.php
@@ -68,18 +68,14 @@ class OnWorkerStart extends Callback
     public function onSignal($server, $worker_id)
     {
         $this->debug(sprintf(workerName($worker_id) . ' #%d is start.....', $worker_id));
-        Coroutine\go(function (Server $server, $worker_id) {
-            $sigkill = Coroutine::waitSignal($this->signal);
-            if ($sigkill === false) {
-                return $server->stop($worker_id, true);
-            }
-            while (Co::stats()['coroutine_num'] > 0) {
-                var_dump(Co::stats()['coroutine_num']);
-                Coroutine::sleep(0.01);
-            }
-
-            return $server->stop($worker_id, true);
-        }, $server, $worker_id);
+//        Coroutine\go(function (Server $server, $worker_id) {
+        Coroutine::waitSignal($this->signal);
+        while (Co::stats()['coroutine_num'] > 0) {
+            var_dump(Co::stats()['coroutine_num']);
+            Coroutine::sleep(0.01);
+        }
+        return $server->stop($worker_id, true);
+//        }, $server, $worker_id);
     }