From 17b4f4479fb7620b5786bcdd579f8067919ceca5 Mon Sep 17 00:00:00 2001
From: fanshuai <1141904845@qq.com>
Date: Mon, 29 Apr 2024 09:53:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=8A=E7=8A=B6=E6=80=81=E5=88=B7=E6=96=B0?=
 =?UTF-8?q?=E6=94=B9=E6=88=90job?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../platform/scheduling/ExperimentInstanceStatusTask.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java
index 6ab8bd58..80f66add 100644
--- a/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java
+++ b/ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/scheduling/ExperimentInstanceStatusTask.java
@@ -47,7 +47,9 @@ public class ExperimentInstanceStatusTask {
                 }
                 if (!StringUtils.equals(oldStatus,experimentIns.getStatus())){
                     experimentIns.setUpdateTime(new Date());
-                    experimentIds.add(experimentIns.getExperimentId());
+                    synchronized (experimentIds) {
+                        experimentIds.add(experimentIns.getExperimentId()); // 线程安全的添加操作
+                    }
                     updateList.add(experimentIns);
                 }
                 experimentInsDao.update(experimentIns);
@@ -81,7 +83,9 @@ public class ExperimentInstanceStatusTask {
         if (updateexperiments.size() > 0) {
             experimentDao.insertOrUpdateBatch(updateexperiments);
             for (int index = 0; index < updateexperiments.size(); index++) {
-                experimentIds.remove(index);
+                synchronized (experimentIds) {
+                    experimentIds.remove(index); // 线程安全的添加操作
+                }
             }
         }
     }