update...

潘钊
1 parent f47e8872
Showing 2 changed files with 10 additions and 0 deletions
src/main/java/com/bsth/data/ThreadMonotor.java
src/main/java/com/bsth/data/gpsdata/arrival/GpsRealAnalyse.java
 package com.bsth.data;
  
 import com.bsth.data.gpsdata.arrival.GpsRealAnalyse;
+import com.bsth.data.gpsdata.thread.GpsDataLoaderThread;
 import com.bsth.data.msg_queue.DirectivePushQueue;
 import com.bsth.data.msg_queue.WebSocketPushQueue;
 import org.slf4j.Logger;
@@ -24,6 +25,11 @@ public class ThreadMonotor extends Thread{
             GpsRealAnalyse.shutdown();
         }
  
+        if(GpsRealAnalyse.isIdle()){
+            //尝试使用网关的GPS实时对照数据
+            GpsDataLoaderThread.setFlag(-1);
+        }
+
         //webSocket 消息推送队列
         if(WebSocketPushQueue.isIdle()){
             log.warn("WebSocketPushQueue isIdle true !!!!");
@@ -50,6 +50,10 @@ public class GpsRealAnalyse {
         return System.currentTimeMillis() - st > 1000 * 20;
     }
  
+    public static boolean isIdle(){
+        return System.currentTimeMillis() - st > 1000 * 30;
+    }
+
     public void analyse(List<GpsEntity> list) {
         try {
             st = System.currentTimeMillis();