modify
This commit is contained in:
@@ -33,7 +33,7 @@ class Crontab extends Component
|
|||||||
|
|
||||||
$redis->set('crontab:' . $name, serialize($crontab));
|
$redis->set('crontab:' . $name, serialize($crontab));
|
||||||
|
|
||||||
$tickTime = time() + $crontab->getTickTime() * 1000;
|
$tickTime = time() + $crontab->getTickTime();
|
||||||
|
|
||||||
$redis->zAdd(self::CRONTAB_KEY, $tickTime, $crontab->getName());
|
$redis->zAdd(self::CRONTAB_KEY, $tickTime, $crontab->getName());
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -38,6 +38,10 @@ class CrontabProcess extends Process
|
|||||||
*/
|
*/
|
||||||
public function onHandler(\Swoole\Process $process): void
|
public function onHandler(\Swoole\Process $process): void
|
||||||
{
|
{
|
||||||
|
$redis = Snowflake::app()->getRedis();
|
||||||
|
$redis->del(ACrontab::CRONTAB_KEY);
|
||||||
|
$redis->release();
|
||||||
|
|
||||||
Timer::tick(1000, function () {
|
Timer::tick(1000, function () {
|
||||||
$startTime = time();
|
$startTime = time();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user