From ad6f85734b6715eb77cc44cce8d436620a14bf57 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 24 Sep 2021 19:01:02 +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 --- http-server/ServerCommand.php | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/http-server/ServerCommand.php b/http-server/ServerCommand.php index a7cdcb37..73aabf38 100644 --- a/http-server/ServerCommand.php +++ b/http-server/ServerCommand.php @@ -118,17 +118,18 @@ class ServerCommand extends Command $this->eventProvider->on(OnBeforeWorkerStart::class, [di(OnServerWorker::class), 'setConfigure']); $this->eventProvider->on(OnWorkerStart::class, [di(WorkerDispatch::class), 'dispatch']); $this->eventProvider->on(OnTaskerStart::class, [di(TaskerDispatch::class), 'dispatch']); - $this->eventProvider->on(OnAfterWorkerStart::class, function () { $lists = HandlerManager::getHandlers(); foreach ($lists as $list) { - foreach ($list as $value) { - /** @var Handler|Closure $list */ - if ($value->callback instanceof \Closure) { - continue; + Coroutine\go(function () use ($list) { + foreach ($list as $value) { + /** @var Handler|Closure $list */ + if ($value->callback instanceof \Closure) { + continue; + } + MiddlewareManager::add($value->callback[0], $value->callback[1], null); } - MiddlewareManager::add($value->callback[0], $value->callback[1], null); - } + }); } }); $manager->start();