We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 79a0902 commit 8df599fCopy full SHA for 8df599f
horus-server/src/main/java/cn/archliu/horus/server/domain/schedule/service/impl/ScheduleServiceImpl.java
@@ -45,8 +45,9 @@ public class ScheduleServiceImpl implements ScheduleService {
45
@Autowired
46
private HorusScheduleHistoryMapper historyMapper;
47
48
+ // TODO 后续可以改造使用 redis 锁进行并发控制,当前先用 synchronized
49
@Override
- public void addCronTask(ScheduleJobDTO scheduleJobDTO) {
50
+ public synchronized void addCronTask(ScheduleJobDTO scheduleJobDTO) {
51
HorusScheduleJob job = ScheduleConvert.INSTANCE.convert(scheduleJobDTO);
52
// 校验 job_code 是否存在
53
boolean exists = new LambdaQueryChainWrapper<>(jobMapper)
0 commit comments