diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php index 28ded719..a501afc1 100644 --- a/System/Crontab/Producer.php +++ b/System/Crontab/Producer.php @@ -67,6 +67,7 @@ class Producer extends Component $redis = Snowflake::app()->getRedis(); $data = $redis->zRange(self::CRONTAB_KEY, 0, -1); foreach ($data as $datum) { + $redis->setex('stop:crontab:' . $datum, 120, 1); $redis->del('crontab:' . $datum); } $redis->release();