From d57c803a5336edddb8a795b2ef1af61e16406e0e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Sat, 1 Apr 2023 23:57:36 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=98=E6=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Abstracts/TraitServer.php | 2 +- CoroutineServer.php | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Abstracts/TraitServer.php b/Abstracts/TraitServer.php index a745dd0..aa15496 100644 --- a/Abstracts/TraitServer.php +++ b/Abstracts/TraitServer.php @@ -70,7 +70,7 @@ trait TraitServer if (get_called_class() != CoroutineServer::class) { pcntl_signal(SIGINT, [$this, 'onSigint']); } else { - Coroutine::create(function () use ($signal, $callback) { + Coroutine::create(static function () use ($signal, $callback) { $data = Coroutine::waitSignal($signal); if ($data) { $callback($signal, [true]); diff --git a/CoroutineServer.php b/CoroutineServer.php index 651cc68..56a1b50 100644 --- a/CoroutineServer.php +++ b/CoroutineServer.php @@ -176,7 +176,7 @@ class CoroutineServer implements ServerInterface $this->onTasker(); foreach ($this->servers as $server) { - Coroutine::create(function () use ($server) { + Coroutine::create(static function () use ($server) { $server->start(); }); } @@ -216,7 +216,7 @@ class CoroutineServer implements ServerInterface $this->channel = new Coroutine\Channel($config[Constant::OPTION_TASK_WORKER_NUM]); for ($i = 0; $i < $config[Constant::OPTION_TASK_WORKER_NUM]; $i++) { - Coroutine::create(fn() => $this->taskRunner($i, $taskEvents, $finishEvents)); + Coroutine::create(static fn() => $this->taskRunner($i, $taskEvents, $finishEvents)); } }