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