This commit is contained in:
2021-03-02 10:28:13 +08:00
parent cca13bb616
commit 6c88a2be13
+3 -6
View File
@@ -48,7 +48,6 @@ class OnWorkerStart extends Callback
} }
/** /**
* @param Server $server * @param Server $server
* @param int $worker_id * @param int $worker_id
@@ -95,12 +94,10 @@ class OnWorkerStart extends Callback
public function onSignal(Server $server, $worker_id): mixed public function onSignal(Server $server, $worker_id): mixed
{ {
$ret = Coroutine::waitSignal($this->signal, -1); $ret = Coroutine::waitSignal($this->signal, -1);
Coroutine::create(function () use ($server) {
var_dump($ret);
if ($ret === true) {
var_dump(Coroutine::waitPid($server->worker_pid, -1)); var_dump(Coroutine::waitPid($server->worker_pid, -1));
});
if ($ret === true) {
$this->ticker(); $this->ticker();
} }
return $server->stop(); return $server->stop();