任务相关

src/main/java/com/hivekion/room/RoomManager.java

@@ -19,8 +19,8 @@ public class RoomManager {
 
   private static final Map<String, Room> roomsMap = new ConcurrentHashMap<>();
 
-  public static void startRoom(String id, Scenario scenario,long time) {
-    Room room = new Room(id,scenario);
+  public static void startRoom(String id, Scenario scenario, long time) {
+    Room room = new Room(id, scenario);
     roomsMap.put(id, room);
     room.start(time);
   }
@@ -52,4 +52,12 @@ public class RoomManager {
       room.addAction(time, action);
     }
   }
+
+  public static long getRoomDuringTime(String id) {
+    Room room = roomsMap.get(id);
+    if (room != null) {
+      return room.getDuringTime();
+    }
+    return 0;
+  }
 }

src/main/java/com/hivekion/room/bean/Room.java

@@ -10,10 +10,8 @@ import com.hivekion.scenario.bean.ScenarioWsParam;
 import java.time.format.DateTimeFormatter;
 import java.util.HashMap;
 import java.util.Map;
-import java.util.Map.Entry;
 import java.util.NavigableMap;
 import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.ConcurrentNavigableMap;
 import java.util.concurrent.ConcurrentSkipListMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
@@ -111,7 +109,12 @@ public class Room implements AutoCloseable {
     startTask();
   }
 
-
+  public long getDuringTime() {
+    return duringTime.get();
+  }
+  public long getTotalTime() {
+    return totalTime.get();
+  }
 
   // 启动定时任务
   private void startTask() {
@@ -134,10 +137,6 @@ public class Room implements AutoCloseable {
              });
           });
 
-
-          // 全部执行后再清空
-
-
           actions.clear();
         }
       }, 0, 1, TimeUnit.SECONDS);