github
/
certd
mirror of https://github.com/certd/certd
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore:

pull/148/head
xiaojunnuo 2024-08-05 16:07:28 +08:00
parent 87e440ee2a
commit 02bb0be06a
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
packages/ui/certd-server/src/modules/plugin/cron/cron.ts
View File

@ -24,6 +24,7 @@ export class CronTask {
this.job = req.job; this.job = req.job;
this.name = req.name; this.name = req.name;
this.logger = logger; this.logger = logger;
this.genNextTime();
} }
genNextTime() { genNextTime() {
@ -68,8 +69,6 @@ export class Cron {
this.logger.error(`job execute error : [${task.name}]`, e); this.logger.error(`job execute error : [${task.name}]`, e);
}); });
task.genNextTime(); task.genNextTime();
} else {
break;
} }
} }
}, 1000 * 60); }, 1000 * 60);
@ -86,12 +85,7 @@ export class Cron {
this.logger.info(`[cron] register cron : [${req.name}] ,${req.cron}`); this.logger.info(`[cron] register cron : [${req.name}] ,${req.cron}`);
const task = new CronTask(req, this.logger); const task = new CronTask(req, this.logger);
task.genNextTime();
this.queue.push(task); this.queue.push(task);
// sort by nextTime
this.queue.sort((a, b) => a.nextTime - b.nextTime);
this.logger.info('当前定时任务数量：', this.getTaskSize()); this.logger.info('当前定时任务数量：', this.getTaskSize());
} }
@ -102,6 +96,7 @@ export class Cron {
this.queue[index].stop(); this.queue[index].stop();
this.queue.splice(index, 1); this.queue.splice(index, 1);
} }
this.logger.info('当前定时任务数量：', this.getTaskSize());
} }
getTaskSize() { getTaskSize() {