modify

2021-03-01 00:25:04 +08:00
parent 5a433b0d7e
commit 88327bfcf6
1 changed files with 2 additions and 1 deletions
@@ -51,7 +51,7 @@ class OnWorkerStart extends Callback
            $this->onWorker($server, $worker_id);
        }

-        Coroutine::create([$this, 'onSignal'], $server, $worker_id);
+        Coroutine\go([$this, 'onSignal'], $server, $worker_id);
    }


@@ -101,6 +101,7 @@ class OnWorkerStart extends Callback
        $env = ucfirst(Snowflake::getEnvironmental());

        $receive = Coroutine::waitSignal($this->signal, -1);
+        var_dump($receive);
        while ($receive === true) {
            if ($this->isPrint === false) {
                $this->warning(sprintf('Receive %s#%d stop event.', $env, $worker_id));