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