潘钊 / bsth_control · Commits

Commit 54cc32a40e402dd6e3aca7bd97882fbfa9535909

Authored by 潘钊
1 parent e7677441

update...

Inline Side-by-side
Showing 1 changed file with 6 additions and 8 deletions
src/main/java/com/bsth/data/ThreadMonotor.java
  View file @54cc32a
@@ -2,8 +2,6 @@ package com.bsth.data; @@ -2,8 +2,6 @@ package com.bsth.data;
2 2
3 import com.bsth.data.gpsdata.arrival.GpsRealAnalyse; 3 import com.bsth.data.gpsdata.arrival.GpsRealAnalyse;
4 import com.bsth.data.gpsdata.thread.GpsDataLoaderThread; 4 import com.bsth.data.gpsdata.thread.GpsDataLoaderThread;
5 -import com.bsth.data.msg_queue.DirectivePushQueue;  
6 -import com.bsth.data.msg_queue.WebSocketPushQueue;  
7 import org.slf4j.Logger; 5 import org.slf4j.Logger;
8 import org.slf4j.LoggerFactory; 6 import org.slf4j.LoggerFactory;
9 import org.springframework.stereotype.Component; 7 import org.springframework.stereotype.Component;
@@ -20,10 +18,10 @@ public class ThreadMonotor extends Thread{ @@ -20,10 +18,10 @@ public class ThreadMonotor extends Thread{
20 public void run() { 18 public void run() {
21 19
22 //线调GPS分析主线程 20 //线调GPS分析主线程
23 - if(GpsRealAnalyse.isBlock()){ 21 + /*if(GpsRealAnalyse.isBlock()){
24 log.warn("GpsRealAnalyse isBlock true !!!!"); 22 log.warn("GpsRealAnalyse isBlock true !!!!");
25 GpsRealAnalyse.shutdown(); 23 GpsRealAnalyse.shutdown();
26 - } 24 + }*/
27 25
28 if(GpsRealAnalyse.isIdle()){ 26 if(GpsRealAnalyse.isIdle()){
29 //切换到备用的网关实时GPS对照数据 27 //切换到备用的网关实时GPS对照数据
@@ -31,15 +29,15 @@ public class ThreadMonotor extends Thread{ @@ -31,15 +29,15 @@ public class ThreadMonotor extends Thread{
31 } 29 }
32 30
33 //webSocket 消息推送队列 31 //webSocket 消息推送队列
34 - if(WebSocketPushQueue.isIdle()){ 32 + /*if(WebSocketPushQueue.isIdle()){
35 log.warn("WebSocketPushQueue isIdle true !!!!"); 33 log.warn("WebSocketPushQueue isIdle true !!!!");
36 WebSocketPushQueue.start(); 34 WebSocketPushQueue.start();
37 - } 35 + }*/
38 36
39 //网关指令推送队列（系统自动发送的） 37 //网关指令推送队列（系统自动发送的）
40 - if(DirectivePushQueue.isIdle()){ 38 + /*if(DirectivePushQueue.isIdle()){
41 log.warn("DirectivePushQueue isIdle true !!!!"); 39 log.warn("DirectivePushQueue isIdle true !!!!");
42 DirectivePushQueue.start(); 40 DirectivePushQueue.start();
43 - } 41 + }*/
44 } 42 }
45 } 43 }
46 \ No newline at end of file 44 \ No newline at end of file