wn/modbusmaster
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

be more cooperative, delay queue feeder by minimum scan rate in register list

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2019-06-24 13:17:09 +02:00
parent 4a090c5a73
commit 37548cfd53
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
snippets/test8.py
View File

@ -95,6 +95,7 @@ class ScanRateConsideringQueueFeeder(threading.Thread):
super(ScanRateConsideringQueueFeeder, self).__init__() super(ScanRateConsideringQueueFeeder, self).__init__()
self.registers = registers self.registers = registers
self.queue = queue self.queue = queue
self.delayEvent = threading.Event()
def run(self): def run(self):
while True: while True:
@ -108,6 +109,7 @@ class ScanRateConsideringQueueFeeder(threading.Thread):
for r in registersToBeHandled: for r in registersToBeHandled:
self.queue.put(r) self.queue.put(r)
r.enqueued = True r.enqueued = True
self.delayEvent.wait(min([r.scanRate.total_seconds() for r in self.registers if r.scanRate]))
class CommunicationProcessor(threading.Thread): class CommunicationProcessor(threading.Thread):