战斗任务消耗资源代码

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

@@ -3,11 +3,8 @@ package com.hivekion.room.bean;
 import com.hivekion.room.RoomManager;
 import com.hivekion.room.func.TaskAction;
 import com.hivekion.scenario.entity.ScenarioTask;
-import java.util.concurrent.LinkedBlockingQueue;
+
-import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.*;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.springframework.web.reactive.function.client.WebClient;
 
@@ -75,6 +72,22 @@ public abstract class AbtParentTask implements TaskAction {
   public boolean getRoomStatus() {
     return RoomManager.isRunning(roomId);
   }
+
+  public void createBattleTaskOnTimingHandle(BizTaskOnTiming bizTaskOnTiming){
+    ScheduledExecutorService schedule = Executors.newScheduledThreadPool(
+            1);
+    schedule.scheduleWithFixedDelay(() -> {
+      bizTaskOnTiming.execTask();
+    }, 0, 10, TimeUnit.SECONDS);
+    //房间统一管理定时器；房间关闭后，定时器销毁
+    addScheduledExecutorServiceRefenceToRoom(schedule);
+  }
+
+}
+
+ interface BizTaskOnTiming{
+
+  public void execTask();
 }
 
 // 自定义线程工厂

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

@@ -69,7 +69,7 @@ public class BattleRootTask extends AbtParentTask  {
   public void doSomeThing() {
     this.initBean();
     if(this.getRoomStatus()) {
-      long initduringTime = this.getDuringTime();
+      long initDuringTime = this.getDuringTime();
       StatisticBean statisticBean = statisticService.statistic(scenarioTask.getResourceId());
 //      statisticBean.getAmmunition().getCurrent()
       //初始化本次战斗任务各种资源数
@@ -80,12 +80,13 @@ public class BattleRootTask extends AbtParentTask  {
       redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"water",statisticBean.getWater().getCurrent());
       redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"person",statisticBean.getPerson().getCurrent());
       redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"team",statisticBean.getPerson().getCurrent());
-      redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"duringTime",initduringTime);
+      redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"duringTime",initDuringTime);
       log.info("===============================初始化本次战斗任务各种资源数====================================");
+
       //定时检查统计各种资源消耗量
-      ScheduledExecutorService schedule = Executors.newScheduledThreadPool(
+      this.createBattleTaskOnTimingHandle(new BizTaskOnTiming() {
-              1);
+        @Override
-      schedule.scheduleWithFixedDelay(() -> {
+        public void execTask() {
           log.info("===============================定时检查统计各种资源消耗量 begin====================================");
           Double teamConsume = null;
           Long personConsume = null;
@@ -160,10 +161,10 @@ public class BattleRootTask extends AbtParentTask  {
             log.error("===========BattleRootTask supplierRequestService.saveBatch error====================",ex.getMessage());
           }
           log.info("===============================定时检查统计各种资源消耗量 end====================================");
-      }, 0, 10, TimeUnit.SECONDS);
+        }
+      });
+
 
-      //房间统一管理定时器；房间关闭后，定时器销毁
-      addScheduledExecutorServiceRefenceToRoom(schedule);
     }