Merge pull request #57 from want-eat-meat/master

fix(tb_device_mqtt):fix high usage of CPU on start
thingsboard · May 2, 2024 · 9bab19a · 9bab19a
2 parents 9197e75 + 2a7a57b
commit 9bab19a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/tb_device_mqtt.py b/tb_device_mqtt.py
@@ -663,6 +663,7 @@ def __sending_thread_main(self):
         while not self.stopped:
             try:
                 if not self.is_connected():
+                    sleep(.1)
                     continue
                 if (not self.__rate_limit.check_limit_reached()
                         and (self.__rate_limit.get_minimal_limit() == 0
@@ -681,6 +682,8 @@ def __sending_thread_main(self):
                                 result = self._client.subscribe(item["topic"], qos=item["qos"])
                                 self.__responses[item['id']] = {"info": result, "timeout_ts": int(time()) + DEFAULT_TIMEOUT}
                                 self.__rate_limit.add_counter()
+                    else:
+                        sleep(.1)
                 else:
                     sleep(0.1)
             except Exception as e: