modify

2021-04-11 04:07:35 +08:00
parent 19cf1b04d9
commit d4b64c3af2
1 changed files with 4 additions and 1 deletions
@@ -48,9 +48,12 @@ class ZookeeperProcess extends Process

 			$redis = Snowflake::app()->getRedis();

+			$redis->multi();
 			$range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
 			$redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
-			$redis->release();
+            $redis->exec();
+
+            $redis->release();

 			/** @var Consumer $consumer */
 			$consumer = Snowflake::app()->get(Consumer::class);