车辆上报判断是否现成,否则会创建多余线程

new-master
dongzeliang 2023-11-29 08:57:35 +08:00
parent 7fd2e3481e
commit 03b635db32
2 changed files with 7 additions and 3 deletions

View File

@ -141,8 +141,12 @@ public class VehicleInstanceServiceImpl implements VehicleInstanceService {
VehicleInstance vehicleInstance = LocalContainer.getVehicleInstance(msgReq.getVin()); VehicleInstance vehicleInstance = LocalContainer.getVehicleInstance(msgReq.getVin());
switch (msgReq.getMsgCode()){ switch (msgReq.getMsgCode()){
case "上报" -> { case "上报" -> {
vehicleInstance.initVehicleThread(); if(vehicleInstance.getVehicleThread() == null){
vehicleInstance.startSend(); vehicleInstance.initVehicleThread();
vehicleInstance.startSend();
}else {
vehicleInstance.pauseSend();
}
} }
case "暂停" -> vehicleInstance.pauseSend(); case "暂停" -> vehicleInstance.pauseSend();
case "停止" -> vehicleInstance.stopSend(); case "停止" -> vehicleInstance.stopSend();

View File

@ -288,7 +288,7 @@ public class VehicleInstance {
/** /**
* *
* @param d * @param gear
*/ */
public void setGear (String gear) { public void setGear (String gear) {
this.vehicleData.setGear(gear); this.vehicleData.setGear(gear);