# -*- coding: utf-8 -*-
# Worker code

from multiprocessing import Process
import logging
import time

class Worker(Process):
    def __init__(self,queue):
        Process.__init__(self)
        self.queue=queue
        
    def run(self):
        logging.info('Worker thread läuft nun...')
        id=0
        while 1:
            job=self.queue.get()
            if job is None:
                break # reached end of queue
            id+=1
            logging.info('ein neuer Job(%d)' %(id))
            try:
                job.start(id)
                logging.info('Job(%d) fertig ;)'%(id))
            except:
                logging.exception('Job(%d) fehlgeschlagen :('%(id))