add .shutdown to scheduler

Author: Günther Jena

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 0.4.7
+
+* adding .shutdown method to schedulers
+
 # 0.4.6
 
 * fix object_dictionary.read in LSS service

src/durand/scheduler.py

@@ -33,6 +33,9 @@ def cancel(self, entry: TEntry):
     @abstractmethod
     def lock(self):
         """A global lock which can be used the assure thread safety"""
+    
+    def shutdown(self):
+        """ Shutting down the scheduler """
 
 
 class AsyncScheduler(AbstractScheduler):
@@ -56,6 +59,8 @@ def cancel(self, entry: asyncio.TimerHandle):  # type: ignore[override]
     @property
     def lock(self):
         return self._lock
+    
+    # nothing happens at shutdown, as no resources have to be freed
 
 
 class SyncScheduler(AbstractScheduler):
@@ -65,6 +70,7 @@ def __init__(self, lock: threading.Lock = None):
         self._lock = lock
         self._sched = sched.scheduler()
         self._wake_up = threading.Event()
+        self._stop = False
 
     def add(
         self, delay: float, callback, args=(), kwargs=None
@@ -82,10 +88,17 @@ def run(self):
             self._sched.run()
             self._wake_up.wait()
             self._wake_up.clear()
+            with self._lock:
+                if self._stop:
+                    break
 
     @property
     def lock(self):
         return self._lock
+    
+    def shutdown(self):
+        self._wake_up.set()
+        self._stop = True
 
 
 class VirtualScheduler(AbstractScheduler):