modify

2021-02-28 17:37:35 +08:00
parent 5dd3b52efa
commit 0f5a2e71d7
1 changed files with 5 additions and 5 deletions
@@ -92,11 +92,11 @@ class OnWorkerStart extends Callback
    public function onSignal()
    {
        Coroutine::create(function () {
-            if (!Coroutine::waitSignal($this->signal)) {
-                return 0;
-            }
-            while (Snowflake::app()->isRun()) {
-                sleep(1);
+            $ret = Coroutine::waitSignal($this->signal, -1);
+            if ($ret) {
+                while (Snowflake::app()->isRun()) {
+                    sleep(1);
+                }
            }
            return Snowflake::app()->getSwoole()->stop();
        });