use walrus

This commit is contained in:
onyx-and-iris 2023-08-04 16:21:07 +01:00
parent 50e95d6b8d
commit cddd04974b
2 changed files with 5 additions and 8 deletions

View File

@ -331,6 +331,7 @@ class Remote(CBindings):
self.logger.info(f"Profile '{name}' applied!")
def end_thread(self):
if self.running:
self.logger.debug("events thread shutdown started")
self.running = False

View File

@ -56,12 +56,7 @@ class Updater(threading.Thread):
Generate _strip_comp, _bus_comp and update level cache if ldirty.
"""
while True:
event = self.queue.get()
if event is None:
self.logger.debug(f"terminating {self.name} thread")
break
while event := self.queue.get():
if event == "pdirty" and self._remote.pdirty:
self._remote.subject.notify(event)
elif event == "mdirty" and self._remote.mdirty:
@ -73,3 +68,4 @@ class Updater(threading.Thread):
self._remote.cache["strip_level"] = self._remote._strip_buf
self._remote.cache["bus_level"] = self._remote._bus_buf
self._remote.subject.notify(event)
self.logger.debug(f"terminating {self.name} thread")