iro/worker.py
changeset 0 a3b6e531f0d2
child 20 0d7ffb9b2c7f
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/iro/worker.py	Thu Oct 22 10:00:01 2009 +0200
@@ -0,0 +1,17 @@
+# -*- coding: utf-8 -*-
+# Worker code
+
+from multiprocessing import Process
+import time
+
+class Worker(Process):
+    def __init__(self,queue):
+        Process.__init__(self)
+        self.queue=queue
+        
+    def run(self):
+        while 1:
+            job=self.queue.get()
+            if job is None:
+                break # reached end of queue
+            job.start()