From 914803e2e67a0e359ebe8a76680e0414a66e023d Mon Sep 17 00:00:00 2001 From: xuhaoxiang <1216720373@qq.com> Date: Mon, 30 Aug 2021 12:02:44 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=91=E5=88=9B=E6=8E=A5=E5=8F=A3=E4=BC=98?= =?UTF-8?q?=E5=8C=96=EF=BC=8C=E4=BF=AE=E6=94=B9=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/ann/demo/job/ScheduledJob.java | 4 ++++ src/main/java/com/ann/demo/job/SchedulerAllJob.java | 3 ++- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/ann/demo/job/ScheduledJob.java b/src/main/java/com/ann/demo/job/ScheduledJob.java index fba5562..1a405ef 100644 --- a/src/main/java/com/ann/demo/job/ScheduledJob.java +++ b/src/main/java/com/ann/demo/job/ScheduledJob.java @@ -17,6 +17,7 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import org.springframework.scheduling.support.CronTrigger; import java.text.SimpleDateFormat; +import java.time.Duration; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.Date; @@ -53,6 +54,7 @@ public class ScheduledJob implements Job { public void execute(JobExecutionContext context) { QuartzUtils.pauseScheduleJob(scheduler, "group1", "job1"); List scanningFiles =new ArrayList(); + LocalDateTime beginTime = LocalDateTime.now(); try { if(start==0){ scanningFiles = scanningFileRepository.findScanningFiles(over); @@ -65,6 +67,8 @@ public class ScheduledJob implements Job { logger.error("执行定时任务出错:{}" ,e.getMessage()); } QuartzUtils.resumeScheduleJob(scheduler, "group1", "job1"); + LocalDateTime endTime = LocalDateTime.now(); + logger.error("总耗时:"+ Duration.between(beginTime,endTime).toMillis()/1000); logger.error("结束时间:{}" ,LocalDateTime.now()); } diff --git a/src/main/java/com/ann/demo/job/SchedulerAllJob.java b/src/main/java/com/ann/demo/job/SchedulerAllJob.java index 0d73307..b794b1f 100644 --- a/src/main/java/com/ann/demo/job/SchedulerAllJob.java +++ b/src/main/java/com/ann/demo/job/SchedulerAllJob.java @@ -61,7 +61,8 @@ public class SchedulerAllJob { */ JobDetail jobDetail = JobBuilder.newJob(ScheduledJob.class).withIdentity("job1", "group1").build(); // 凌晨1点-凌晨7点 每隔1分钟执行一次 - CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0 0/5 0,1,2,3,4,5,6,7 * * ? "); +// CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0 */1 * * * ?"); + CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0 0 0,1,2,3,4,5,6,7,19,20,21,22,23 * * ? "); // CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0/1 * 16,17,18,19 * * ? "); CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("job1", "group1").withSchedule(scheduleBuilder).build(); scheduler.scheduleJob(jobDetail, cronTrigger);