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