From 0dcc566d84f109a6026c60aeaebe4187a34f892d Mon Sep 17 00:00:00 2001 From: rcoh Date: Tue, 2 Aug 2011 22:02:50 -0700 Subject: adding driver classes and a demo of how to use them. --- driverdemo.py | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) create mode 100644 driverdemo.py (limited to 'driverdemo.py') diff --git a/driverdemo.py b/driverdemo.py new file mode 100644 index 0000000..1c359b5 --- /dev/null +++ b/driverdemo.py @@ -0,0 +1,30 @@ +from drivers import * +from threading import * +import Queue +class TestProcessor(Processor): + def do(self): + data = [] + if not self.input_queue.empty(): + data.append(self.input_queue.get(False)) + self.again(.1) + self.done(data) + +class TestListener(Listener): + def handle(self, data): + print data + print active_count() + +def addToQueue(): + queue.put("test") + again = Timer(.5, addToQueue) + again.start() + +queue = Queue.Queue() +t = TestProcessor(queue) +l = TestListener() +t.listeners.append(l) +queue = t.input_queue +t.do() +addToQueue() + + -- cgit v1.2.3