From 93e97d15f22b6b3df53db0ab91a4a309c7d3f775 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sat, 24 Apr 2021 00:27:24 +0800 Subject: [PATCH] modify --- Database/Pagination.php | 2 -- HttpServer/Events/OnPipeMessage.php | 4 ---- 2 files changed, 6 deletions(-) diff --git a/Database/Pagination.php b/Database/Pagination.php index 4430b43a..7f1b65ee 100644 --- a/Database/Pagination.php +++ b/Database/Pagination.php @@ -35,8 +35,6 @@ class Pagination extends Component /** @var Closure */ private Closure $_callback; - /** @var Coroutine\WaitGroup */ - private Coroutine\WaitGroup $_group; /** * PaginationIteration constructor. diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php index e956cda8..a11a2615 100644 --- a/HttpServer/Events/OnPipeMessage.php +++ b/HttpServer/Events/OnPipeMessage.php @@ -28,9 +28,6 @@ class OnPipeMessage extends Callback */ public function onHandler(Server $server, int $src_worker_id, $swollen_universalize) { - defer(function () { - fire(Event::SYSTEM_RESOURCE_RELEASES); - }); match ($swollen_universalize['action'] ?? null) { 'kafka' => $this->onKafkaWorker($swollen_universalize), 'crontab' => $this->onCrontabWorker($swollen_universalize), @@ -66,7 +63,6 @@ class OnPipeMessage extends Callback $redis->zAdd(Producer::CRONTAB_KEY, $tickTime, $name); } } - fire(Event::SYSTEM_RESOURCE_RELEASES); }); $handler->increment()->execute(); return 'success';