save.py 文件源码

def __init__(self, count, func, end_clause='end', **func_kwargs):
        self.count = count
        self.func = func
        self.queue = multiprocessing.JoinableQueue()
        self.end_clause = end_clause
        self.func_kwargs = func_kwargs