Thirdparty
/
wvp-GB28181-pro
mirror of https://github.com/648540858/wvp-GB28181-pro
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

redis 允许正在进行的任务完成

pull/1023/head
chenzhangyue 2023-08-10 19:18:49 +08:00
parent 8e34d4e4cb
commit dfd7566274
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/genersoft/iot/vmp/conf/DynamicTask.java
View File

@ -111,7 +111,7 @@ public class DynamicTask {
} }
boolean result = false; boolean result = false;
if (!ObjectUtils.isEmpty(futureMap.get(key)) && !futureMap.get(key).isCancelled() && !futureMap.get(key).isDone()) { if (!ObjectUtils.isEmpty(futureMap.get(key)) && !futureMap.get(key).isCancelled() && !futureMap.get(key).isDone()) {
result = futureMap.get(key).cancel(true); result = futureMap.get(key).cancel(false);
futureMap.remove(key); futureMap.remove(key);
runnableMap.remove(key); runnableMap.remove(key);
} }
@ -143,7 +143,8 @@ public class DynamicTask {
public void execute(){ public void execute(){
if (futureMap.size() > 0) { if (futureMap.size() > 0) {
for (String key : futureMap.keySet()) { for (String key : futureMap.keySet()) {
if (futureMap.get(key).isDone() || futureMap.get(key).isCancelled()) { ScheduledFuture<?> future = futureMap.get(key);
if (future.isDone() || future.isCancelled()) {
futureMap.remove(key); futureMap.remove(key);
runnableMap.remove(key); runnableMap.remove(key);
} }