processpool.py 文件源码

def __init__(self, num_processes, handle_queue_size, output_queue_size=0):
        self.__workers = []
        self.__num_processes = num_processes
        self.__queue = multiprocessing.JoinableQueue(handle_queue_size)
        if output_queue_size != 0:
            self.__output = multiprocessing.JoinableQueue(output_queue_size)
        else:
            self.__output = None
        pass