woker.py 文件源码

def __init__(self, worker_nums=None, callback=None):
        if worker_nums is not None:
            self.__worker_nums = worker_nums

        self.master_pid = os.getpid()
        self.queue = multiprocessing.JoinableQueue()
        self.__callback = callback

        # create worker
        self.__create_worker()