From d6622a2b0bf023ff26761c31e32f4ee6c9256325 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Mon, 1 Mar 2021 17:46:10 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- HttpServer/Events/OnWorkerStart.php | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index 1ef608e4..852f51e6 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -92,18 +92,21 @@ class OnWorkerStart extends Callback * @param $worker_id * @return mixed */ - public function onSignal(Server $server, $worker_id): mixed + public function onSignal(Server $server, $worker_id): void { $ret = Coroutine::waitSignal($this->signal, -1); - if ($ret === true) { - $this->ticker(); - } - return $server->stop($worker_id); + Coroutine\go(function ($ret, $server, $worker_id) { + if ($ret === true) { + $this->ticker(); + } + return $server->stop($worker_id); + }, $ret, $server, $worker_id); } /** * @return void + * @throws ComponentException */ private function ticker(): void {