sswarm.py 文件源码

python
阅读 24 收藏 0 点赞 0 评论 0

项目:swarm 作者: a7vinx 项目源码 文件源码
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')
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号