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