Merge pull request #3 from Pubaluba/Threading-patch

Threading patch
tjhowse · Jan 22, 2024 · 8bfee82 · 8bfee82 · pki791 · Jan 23, 2024
2 parents c6f6db3 + 5a946d2
commit 8bfee82
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/modbus4mqtt.py b/modbus4mqtt.py
@@ -8,9 +8,10 @@
 from ccorp.ruamel.yaml.include import YAML
 import click
 import paho.mqtt.client as mqtt
+import threading
 
 from . import modbus_interface
-version = "EW.0.81"
+version = "EW.0.9"
 MAX_DECIMAL_POINTS = 3
 DEFAULT_SCAN_RATE_S = 5
 
@@ -380,8 +381,10 @@ def _load_modbus_config(self, path):
     def loop_forever(self):
         while True:
             # TODO this properly.
-            self.poll()
+            pollthread = threading.Thread(target = self.poll, args = ())
+            pollthread.start()
             sleep(self.config.get('update_rate', DEFAULT_SCAN_RATE_S))
+            pollthread.join()
 
     def singlerun(self):
             self.poll()