sswarm.py 文件源码

def get_do_task(self):
        proc=[]
        if self._args.process_num==0:
            for cur in range(multiprocessing.cpu_count()):
                p=multiprocessing.Process(target=self._get_do_task_proc)
                p.start()
                proc.append(p)
        else:
            for cur in range(self._args.process_num):
                p=multiprocessing.Process(target=self._get_do_task_proc)
                p.start()
                proc.append(p)
        # start a new thread to listen command from master host
        # use daemon argtment so we need not to wait for this thread to exit
        t=threading.Thread(target=self._response_master)
        t.daemon=True
        t.start()
        for cur in proc:
            cur.join()
        LOG.debug('task completed')