multiprocessor.py 文件源码

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

项目:sparks 作者: ImpactHorizon 项目源码 文件源码
def __init__(self, 
                    functions, 
                    output_names=['val'], 
                    initializator=None, 
                    initializator_args={}, 
                    max_size=1024, 
                    threads_num=8, 
                    update=False,
                    resources_demanded=1,
                    mode="consumer",
                    counter=None):

        self.functions = functions
        self.output_names = output_names
        self.initializator = initializator
        self.initializator_args = initializator_args
        self.threads_num = threads_num
        self.update = update
        self.resources_demanded = resources_demanded
        self.mode = mode
        self.counter = counter

        self.out_queue = JoinableQueue(max_size)

        self.in_queue = None
        self.runners = None
        self.runners_events = None
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号