This commit is contained in:
2021-03-01 18:06:21 +08:00
parent be9f3de663
commit 5ffec900d7
+12 -14
View File
@@ -91,23 +91,21 @@ class OnWorkerStart extends Callback
* @param $server * @param $server
* @param $worker_id * @param $worker_id
* @return mixed * @return mixed
* @throws ComponentException
*/ */
public function onSignal(Server $server, $worker_id): void public function onSignal(Server $server, $worker_id): mixed
{ {
$ret = Coroutine::waitSignal($this->signal, -1); $ret = Coroutine::waitSignal($this->signal, -1);
Coroutine\go(function ($ret, Server $server, $worker_id) { if ($server->getWorkerStatus() == false) {
var_dump($server->worker_pid); return 0;
if ($server->getWorkerStatus() == false) { }
return 0; if ($server->getWorkerStatus() == 3) {
} return 0;
if ($server->getWorkerStatus() == 3) { }
return 0; if ($ret === true) {
} $this->ticker();
if ($ret === true) { }
$this->ticker(); return $server->stop();
}
return $server->stop($worker_id);
}, $ret, $server, $worker_id);
} }