1 # -*- coding: utf-8 -*-

     2 # Worker code

     3 

     4 from multiprocessing import Process

     5 import time

     6 

     7 class Worker(Process):

     8     def __init__(self,queue):

     9         Process.__init__(self)

    10         self.queue=queue

    11         

    12     def run(self):

    13         while 1:

    14             job=self.queue.get()

    15             if job is None:

    16                 break # reached end of queue

    17             job.start()