使用python的futures.ThreadPoolExecutor是,如果你调用submit提交任务ThreadPoolExecutor会执行self._work_queue.put(w)其中self._work_queue=queue.SimpleQueue()SimpleQueue是一个unlimitedqueue的大小,如果提交的任务过多,处理不及时,会占用太多内存,可以通过_work_queue的实现来代替,使用queue.Queue(maxsize=maxsize)classThreadPoolExecutorWithQueueSizeLimit(futures.ThreadPoolExecutor):def__init__(self,maxsize=50,*args,**kwargs):super(ThreadPoolExecutorWithQueueSizeLimit,self).__init__(*args,**kwargs)self._work_queue=queue.Queue(maxsize=maxsize)链接:https://stackoverflow.com/问...
