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')
评论列表
文章目录