perf: 控制仅一个刷新任务

dev
huangfeng 1 month ago
parent ada58f7647
commit d4657abe64

@ -46,6 +46,7 @@ public class StoreCameraScheduleTask {
TermSetService termSetService; TermSetService termSetService;
private int shutdown = 0; private int shutdown = 0;
private boolean inDoing = false;
@PreDestroy @PreDestroy
private void preDestroy() { private void preDestroy() {
@ -99,6 +100,11 @@ public class StoreCameraScheduleTask {
if (!enable) { if (!enable) {
return; return;
} }
if (inDoing) {
return;
}
inDoing = true;
log.info("开始查询全部装置拍照时间表");
Map<Integer, Terminals> terminalMap = newCacheService.getTerminalMap(); Map<Integer, Terminals> terminalMap = newCacheService.getTerminalMap();
Map<Integer, TermAndChannelDto> termAndChannelMap = cacheService.getTermAndChannelMap(); Map<Integer, TermAndChannelDto> termAndChannelMap = cacheService.getTermAndChannelMap();
Iterator<Integer> it = terminalMap.keySet().iterator(); Iterator<Integer> it = terminalMap.keySet().iterator();
@ -108,10 +114,12 @@ public class StoreCameraScheduleTask {
TermAndChannelDto termAndChannelDto = termAndChannelMap.get(termId); TermAndChannelDto termAndChannelDto = termAndChannelMap.get(termId);
this.searchOne(term, termAndChannelDto); this.searchOne(term, termAndChannelDto);
try { try {
Thread.sleep(200); Thread.sleep(300);
} catch (Exception ignore) { } catch (Exception ignore) {
} }
} }
log.info("查询全部装置拍照时间表完成");
inDoing = false;
} }
private void searchOne(Terminals term, TermAndChannelDto termAndChannelDto) { private void searchOne(Terminals term, TermAndChannelDto termAndChannelDto) {

Loading…
Cancel
Save