36 lines
1.3 KiB
Python
36 lines
1.3 KiB
Python
|
import threading
|
||
|
|
import datetime
|
||
|
|
from AbstractNotificationReceiver import AbstractNotificationReceiver
|
||
|
|
|
||
|
|
|
||
|
|
class ScanRateConsideringQueueFeeder(threading.Thread, AbstractNotificationReceiver):
|
||
|
|
def __init__(self, config, registers, queue):
|
||
|
|
super().__init__()
|
||
|
|
self.config = config
|
||
|
|
self.registers = registers
|
||
|
|
self.queue = queue
|
||
|
|
self.delayEvent = threading.Event()
|
||
|
|
|
||
|
|
def getMinimalScanrate(self):
|
||
|
|
return min([r.scanRate.total_seconds() for r in self.registers if r.scanRate])
|
||
|
|
|
||
|
|
def receiveNotification(self, arg):
|
||
|
|
print("ScanRateConsideringQueueFeeder:registersChanged")
|
||
|
|
self.delay = self.getMinimalScanrate()
|
||
|
|
|
||
|
|
def run(self):
|
||
|
|
self.delay = self.getMinimalScanrate()
|
||
|
|
while True:
|
||
|
|
registersToBeHandled = [
|
||
|
|
r for r in self.registers if ((not r.enqueued) and
|
||
|
|
(r.scanRate) and
|
||
|
|
((not r.lastContact) or
|
||
|
|
(r.lastContact + r.scanRate < datetime.datetime.now())))
|
||
|
|
]
|
||
|
|
registersToBeHandled.sort(key=lambda x : x.scanRate)
|
||
|
|
for r in registersToBeHandled:
|
||
|
|
r.setCommand('r')
|
||
|
|
self.queue.put(r)
|
||
|
|
r.enqueued = True
|
||
|
|
self.delayEvent.wait(self.delay)
|