third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

perf: optimize DailyTimeIntervalStrategyHandler

Browse Source
This commit is contained in:
tjq 2023-02-11 23:02:26 +08:00
parent 42823b8bdd
commit e01770adc7
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/scheduler/auxiliary/impl/DailyTimeIntervalStrategyHandler.java
View File

@ -5,6 +5,7 @@ import lombok.Data;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils; import org.apache.commons.lang3.time.DateUtils;
import org.springframework.stereotype.Component;
import tech.powerjob.common.enums.TimeExpressionType; import tech.powerjob.common.enums.TimeExpressionType;
import tech.powerjob.common.serialize.JsonUtils; import tech.powerjob.common.serialize.JsonUtils;
import tech.powerjob.common.utils.CollectionUtils; import tech.powerjob.common.utils.CollectionUtils;
@ -25,6 +26,7 @@ import java.util.concurrent.TimeUnit;
* @author 550w * @author 550w
* @date 2027/02/15 * @date 2027/02/15
*/ */
@Component
public class DailyTimeIntervalStrategyHandler implements TimingStrategyHandler { public class DailyTimeIntervalStrategyHandler implements TimingStrategyHandler {
/** /**
@ -47,6 +49,7 @@ public class DailyTimeIntervalStrategyHandler implements TimingStrategyHandler {
TimeOfDay startTime = TimeOfDay.from(ep.startTimeOfDay); TimeOfDay startTime = TimeOfDay.from(ep.startTimeOfDay);
TimeOfDay endTime = TimeOfDay.from(ep.endTimeOfDay); TimeOfDay endTime = TimeOfDay.from(ep.endTimeOfDay);
if (endTime.before(startTime)) { if (endTime.before(startTime)) {
throw new IllegalArgumentException("endTime should after startTime!"); throw new IllegalArgumentException("endTime should after startTime!");
} }
@ -96,7 +99,7 @@ public class DailyTimeIntervalStrategyHandler implements TimingStrategyHandler {
// 判断是否符合"日"的执行条件 // 判断是否符合"日"的执行条件
int week = TimeUtils.calculateWeek(year, month, day); int week = TimeUtils.calculateWeek(year, month, day);
Set<Integer> targetDays = CollectionUtils.isEmpty(ep.daysOfWeek) ? ALL_DAY : ep.daysOfWeek; Set<Integer> targetDays = CollectionUtils.isEmpty(ep.daysOfWeek) ? ALL_DAY : ep.daysOfWeek;
// 未包含情况下，将时间改写为符合条件日的 00:00 分，重新开始 loop（这部分应该有性能更优的写法，不过这个调度模式应该很难触发瓶颈，先简单好用的实现） // 未包含情况下，将时间改写为符合条件日的 00:00 分，重新开始递归（这部分应该有性能更优的写法，不过这个调度模式应该很难触发瓶颈，先简单好用的实现）
if (!targetDays.contains(week)) { if (!targetDays.contains(week)) {
simpleSetCalendar(calendar, 0, 0, 0); simpleSetCalendar(calendar, 0, 0, 0);
Date tomorrowZero = DateUtils.addDays(calendar.getTime(), 1); Date tomorrowZero = DateUtils.addDays(calendar.getTime(), 1);
@ -108,15 +111,15 @@ public class DailyTimeIntervalStrategyHandler implements TimingStrategyHandler {
simpleSetCalendar(calendar, rangeStartTime.getHour(), rangeStartTime.getMinute(), rangeStartTime.getSecond()); simpleSetCalendar(calendar, rangeStartTime.getHour(), rangeStartTime.getMinute(), rangeStartTime.getSecond());
long todayStartTs = calendar.getTimeInMillis(); long todayStartTs = calendar.getTimeInMillis();
TimeOfDay rangeEndTime = TimeOfDay.from(ep.endTimeOfDay);
simpleSetCalendar(calendar, rangeEndTime.getHour(), rangeEndTime.getMinute(), rangeEndTime.getSecond());
long todayEndTs = calendar.getTimeInMillis();
// 未开始 // 未开始
if (time < todayStartTs) { if (time < todayStartTs) {
return todayStartTs; return todayStartTs;
} }
TimeOfDay rangeEndTime = TimeOfDay.from(ep.endTimeOfDay);
simpleSetCalendar(calendar, rangeEndTime.getHour(), rangeEndTime.getMinute(), rangeEndTime.getSecond());
long todayEndTs = calendar.getTimeInMillis();
// 范围之间 // 范围之间
if (time <= todayEndTs) { if (time <= todayEndTs) {
return time; return time;