From 2f20cbaddc33ac7a1d27f34780c2ca7f3fbda193 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Fri, 16 Apr 2021 01:41:01 +0800 Subject: [PATCH] modify --- System/Crontab/Zookeeper.php | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 3228eb56..6f4fc32b 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -37,7 +37,6 @@ class Zookeeper extends Process $this->dispatch($server, $redis, $setting, $value); } $redis->release(); - sleep(1); } } @@ -76,11 +75,7 @@ class Zookeeper extends Process private function loadCarobTask(): array { $redis = Snowflake::app()->getRedis(); - if (!$redis->exists(Producer::CRONTAB_KEY)) { - var_dump('queue cache not found.'); - } else { - var_dump('queue cache found.'); - } + $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)time()); $redis->zRem(Producer::CRONTAB_KEY, ...$range);