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

from multiprocessing import Process
import logging
logger = logging.getLogger("iro.worker")
import time

class Worker(Process):
    def __init__(self,queue):
        Process.__init__(self)
        self.queue=queue
        
    def run(self):
        logger.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
            logger.info('ein neuer Job(%d)' %(id))
            try:
                job.start(id)
                logger.info('Job(%d) fertig ;)'%(id))
            except:
                logger.exception('Job(%d) fehlgeschlagen :('%(id))