修改间隔时间
This commit is contained in:
@@ -69,10 +69,10 @@ public class JobCleanService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 定时任务A:岗位清洗(每5分钟)
|
* 定时任务A:岗位清洗(每3分钟)
|
||||||
* <p>1. 批量锁定待清洗数据 2. 多线程并发调用AI清洗 3. 写入业务表</p>
|
* <p>1. 批量锁定待清洗数据 2. 多线程并发调用AI清洗 3. 写入业务表</p>
|
||||||
*/
|
*/
|
||||||
@Scheduled(cron = "0 */1 * * * ?")
|
@Scheduled(cron = "0 */3 * * * ?")
|
||||||
public void cleanJob() {
|
public void cleanJob() {
|
||||||
List<AppJobData> dataList = jobCleanTransactionService.lockBatch(batchSize);
|
List<AppJobData> dataList = jobCleanTransactionService.lockBatch(batchSize);
|
||||||
if (dataList.isEmpty()) {
|
if (dataList.isEmpty()) {
|
||||||
|
|||||||
Reference in New Issue
Block a user