Browse Source

把状态刷新改成job

pull/41/head
fanshuai 1 year ago
parent
commit
17b4f4479f
1 changed files with 6 additions and 2 deletions
  1. +6
    -2
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java

+ 6
- 2
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java View File

@@ -47,7 +47,9 @@ public class ExperimentInstanceStatusTask {
} }
if (!StringUtils.equals(oldStatus,experimentIns.getStatus())){ if (!StringUtils.equals(oldStatus,experimentIns.getStatus())){
experimentIns.setUpdateTime(new Date()); experimentIns.setUpdateTime(new Date());
experimentIds.add(experimentIns.getExperimentId());
synchronized (experimentIds) {
experimentIds.add(experimentIns.getExperimentId()); // 线程安全的添加操作
}
updateList.add(experimentIns); updateList.add(experimentIns);
} }
experimentInsDao.update(experimentIns); experimentInsDao.update(experimentIns);
@@ -81,7 +83,9 @@ public class ExperimentInstanceStatusTask {
if (updateexperiments.size() > 0) { if (updateexperiments.size() > 0) {
experimentDao.insertOrUpdateBatch(updateexperiments); experimentDao.insertOrUpdateBatch(updateexperiments);
for (int index = 0; index < updateexperiments.size(); index++) { for (int index = 0; index < updateexperiments.size(); index++) {
experimentIds.remove(index);
synchronized (experimentIds) {
experimentIds.remove(index); // 线程安全的添加操作
}
} }
} }
} }


Loading…
Cancel
Save