From b1b42e053dcdf85534541858ceac98756b199c32 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Mon, 29 Mar 2021 15:05:35 +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 --- System/Crontab/ZookeeperProcess.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/System/Crontab/ZookeeperProcess.php b/System/Crontab/ZookeeperProcess.php index ba6dacbb..b6bb2895 100644 --- a/System/Crontab/ZookeeperProcess.php +++ b/System/Crontab/ZookeeperProcess.php @@ -58,6 +58,7 @@ class ZookeeperProcess extends Process $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); + $redis->release(); /** @var Consumer $consumer */ $consumer = Snowflake::app()->get(Consumer::class); @@ -65,7 +66,6 @@ class ZookeeperProcess extends Process foreach ($range as $value) { $consumer->write('crontab:' . md5($value)); } - $redis->release(); }); }