X-Git-Url: https://git.ralfj.de/saartuer.git/blobdiff_plain/226118cbaed9b2f092e2ae764260bf3b63951938..a7c0b8e1ba3fc6170f14bb0c964e5ac9e9ba4881:/waker.py?ds=sidebyside

diff --git a/waker.py b/waker.py
deleted file mode 100644
index 9c2cf06..0000000
--- a/waker.py
+++ /dev/null
@@ -1,39 +0,0 @@
-from libtuer import ThreadRepeater
-from collections import namedtuple
-from threading import Lock
-
-SLEEP_TIME = 0.5
-
-ToBeWoken = namedtuple('ToBeWoken','f period time_since_call one_shot')
-
-class Waker():
-	def __init__(self, sm):
-		self._sm = sm
-		self._t = ThreadRepeater(self._wake, SLEEP_TIME, name="Waker")
-		self._tobewokens = []
-		self._tobewokens_lock = Lock()
-	
-	def register(f, time, one_shot = False):
-		'''Register a function which is called approximately every <time> seconds (or just once, if one_shot is True). f should return quickly, or it will delay the waker!'''
-		time = max(time//SLEEP_TIME, 1)
-		with self._tobewokens_lock:
-			self._tobewokens.append(ToBeWoken(f, time, 0, one_shot))
-	
-	def _wake(self):
-		with self._tobewokens_lock:
-			delete = []
-			# run the functions we ought to run
-			for tobewoken, idx in zip(self._tobewokens, range(len(self._tobewokens))):
-				tobewoken.time_since_call += 1
-				if tobewoken.time_since_call >= tobewoken.period:
-					tobewoken.f()
-					tobewoken.time_since_call = 0
-					if tobewoken.one_shot:
-						delete.append(idx)
-			# delete what we have to delete - in reverse order so the indices stay valid!
-			delete.reverse()
-			for idx in delete:
-				del self._tobewokens[idx]
-	
-	def stop(self):
-		self._t.stop()