From 411c39f259304cfa991d03e795d0c93e8a402cb6 Mon Sep 17 00:00:00 2001
From: nanotube <nanotube>
Date: Tue, 22 Nov 2005 23:52:29 +0000
Subject: [PATCH] create a repeating timer for autoflushing the buffer.

---
 mytimer.py | 53 +++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)
 create mode 100644 mytimer.py

diff --git a/mytimer.py b/mytimer.py
new file mode 100644
index 0000000..011852e
--- /dev/null
+++ b/mytimer.py
@@ -0,0 +1,53 @@
+from threading import Thread, Event
+import time
+
+class MyTimer(Thread):
+    """Call a function after a specified number of seconds. Repeat a specified number of times:
+
+    Set repetitions to 0 to do this forever (until cancel is called).
+    t = Timer(30.0, 5, f, args=[], kwargs={})
+    t.start()
+    t.cancel() # stop the timer's action if it's still waiting
+    """
+    # This timer is modeled after the original Timer class in the python threading package
+
+    def __init__(self, interval, repetitions, function, args=[], kwargs={}):
+        Thread.__init__(self)
+        self.interval = interval
+        self.repetitions = repetitions
+        self.function = function
+        self.args = args
+        self.kwargs = kwargs
+        self.finished = Event()
+
+    def cancel(self):
+        """Stop the timer if it hasn't finished yet"""
+        self.finished.set()
+
+    def run(self):
+        if self.repetitions != 0:
+            for i in range(0, self.repetitions):
+                self.finished.wait(self.interval)
+                if not self.finished.isSet():
+                    self.function(*self.args, **self.kwargs)
+        else:
+            while not self.finished.isSet():
+                self.finished.wait(self.interval)
+                if not self.finished.isSet():
+                    self.function(*self.args, **self.kwargs)
+
+
+if __name__ == '__main__':
+    #some test code here. 
+    def hello():
+        print "hello dude"
+
+    myt = MyTimer(1.0, 5, hello)
+    myt.start()
+    time.sleep(4)
+    myt.cancel()
+    print "next timer"
+    myt = MyTimer(1.0, 0, hello)
+    myt.start()
+    time.sleep(6)
+    myt.cancel()
-- 
2.45.1