modify

2021-02-28 14:30:11 +08:00
parent 480e87d70b
commit a44b48b372
1 changed files with 3 additions and 1 deletions
@@ -68,7 +68,9 @@ class OnWorkerStart extends Callback
    {
        $this->debug(sprintf(workerName($worker_id) . ' #%d is start.....', $worker_id));
        Coroutine\go(function (Server $server, $worker_id) {
-            Coroutine::waitSignal($this->signal);
+            if (!Coroutine::waitSignal($this->signal)) {
+                return 0;
+            }
            while (Snowflake::app()->isRun()) {
                Coroutine::sleep(1);
            }