python 的线程池应用的是一种生产者消费者的模型

from concurrent.futures import ThreadPoolExecutorfrom loguru import loggerimport requestsimport timepool = ThreadPoolExecutor(max_workers=10)def func_get():    response = requests.get('http://127.0.0.1:5002')    time.sleep(10)def func_callback():    passfor i in range(100):    feature = pool.submit(func_get)    feature.add_done_callback(func_callback)

在其余线程中调用 pool 的 queue 的 submit 接口的时候,task 会被提交给 pool 中的 queue

work thread 会从 queue 中去工作做,如果队列为空,则阻塞挂起

from concurrent.futures import ThreadPoolExecutorpool = ThreadPoolExecutor(max_workers=10)pool._work_queue.qsize()

能够应用 _work_queue 拜访到这个外部队列