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