modify

2021-02-27 02:45:55 +08:00
parent 1003e403b7
commit 6118bdd657
1 changed files with 9 additions and 7 deletions
@@ -60,14 +60,16 @@ class OnWorkerStart extends Callback
     */
    public function onTaskSignal(Server $server, int $workerId)
    {
-        $sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1, -1);
-        if ($sigkill !== false) {
-            while (Snowflake::app()->isRun()) {
-                sleep(1);
+        go(function () use ($server, $workerId) {
+            $sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1, -1);
+            if ($sigkill !== false) {
+                while (Snowflake::app()->isRun()) {
+                    sleep(1);
+                }
            }
-        }
-        Snowflake::app()->stateInit();
-        $server->stop();
+            Snowflake::app()->stateInit();
+            $server->stop();
+        });
    }