第二版

src/main/java/com/care/bms/mqtt/MqttMessageListener.java

@@ -167,6 +167,8 @@ public class MqttMessageListener implements IMqttMessageListener {
                         if(key.startsWith("FallDown")) {
                             if(!value.isInterrupted()){
                                 value.interrupt();//停止线程
+                                threadMap.remove(key);
+                                value = null;
                             }
                         }
                     });
@@ -175,6 +177,8 @@ public class MqttMessageListener implements IMqttMessageListener {
                         if(key.startsWith("StayTooLong")) {
                             if(!value.isInterrupted()){
                                 value.interrupt();//停止线程
+                                threadMap.remove(key);
+                                value = null;
                             }
                         }
                     });