# -*- 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):

        id=0

        while 1:

            job=self.queue.get()

            if job is None:

                break # reached end of queue

            id+=1

            try:

                job.start(id)

            except: