From a5318aa79f5d41391b2b32bbcab54b6210dc5d56 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 26 Feb 2021 19:31:04 +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 | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/HttpServer/Events/OnWorkerStart.php b/HttpServer/Events/OnWorkerStart.php index 9f9544a1..68d2d817 100644 --- a/HttpServer/Events/OnWorkerStart.php +++ b/HttpServer/Events/OnWorkerStart.php @@ -8,6 +8,7 @@ use Exception; use HttpServer\Abstracts\Callback; use Snowflake\Abstracts\Config; use Snowflake\Event; +use Snowflake\Exception\ComponentException; use Snowflake\Exception\ConfigException; use Snowflake\Snowflake; use Swoole\Coroutine; @@ -53,6 +54,7 @@ class OnWorkerStart extends Callback * @param Server $server * @param int $workerId * 异步任务管制 + * @throws ComponentException */ public function onTaskSignal(Server $server, int $workerId) { @@ -62,8 +64,8 @@ class OnWorkerStart extends Callback return $server->stop($workerId); } - var_dump(env('workerId') . '::' . $server->getWorkerStatus($workerId)); - var_dump(env('workerId') . '::' . $server->stats()['coroutine_num']); + $this->error(env('workerId') . '::' . $server->getWorkerStatus($workerId)); + $this->error(env('workerId') . '::' . $server->stats()['coroutine_num']); while ($server->getWorkerStatus($workerId) === SWOOLE_WORKER_BUSY) { Coroutine::sleep(0.01);