diff -r 000000000000 -r a3b6e531f0d2 iro/worker.py --- /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()