TestKMeans_Shared.py 文件源码

def setUp(self):
        # Create a JobQ (to hold tasks to be done)
        # and a ResultsQ (to hold results of completed tasks)
        manager = multiprocessing.Manager()
        self.JobQ = manager.Queue()
        self.ResultQ = manager.Queue()

        # Launch desired number of worker processes
        # We don't need to store references to these processes,
        # We can get everything we need from JobQ and ResultsQ
        # SHARED MEM: we need to give workers access to shared memory at
        # startup
        for uid in range(self.nWorkers):
            SharedMemWorker(
                uid, self.JobQ, self.ResultQ,
                Xsh=self.Xsh,
                Msh=self.Msh,
                returnVal=self.returnVal,
                sleepPerUnit=self.sleepPerUnit,
                verbose=self.verbose).start()