This commit is contained in:
2021-03-02 10:24:22 +08:00
parent 9e11a0fd13
commit e890ffe11d
+5 -1
View File
@@ -45,6 +45,10 @@ class OnWorkerStart extends Callback
} }
$this->debug(sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid)); $this->debug(sprintf('%s #%d Pid:%d start.', ucfirst(env('environmental')), $worker_id, $server->worker_pid));
Coroutine\go([$this, 'onSignal'], $server, $worker_id); Coroutine\go([$this, 'onSignal'], $server, $worker_id);
Coroutine\go(function (Server $server) {
$result = Coroutine::waitPid($server->worker_pid, -1);
var_dump($result);
}, $server);
} }
@@ -96,7 +100,7 @@ class OnWorkerStart extends Callback
$ret = Coroutine::waitSignal($this->signal, -1); $ret = Coroutine::waitSignal($this->signal, -1);
if ($ret === true) { if ($ret === true) {
var_dump(Coroutine::waitPid($worker_id, 1)); var_dump(Coroutine::waitPid($server->worker_pid, -1));
$this->ticker(); $this->ticker();
} }