from concurrent.futures import ThreadPoolExecutor
from loguru import logger
import requests
import time
pool = ThreadPoolExecutor(max_<a href="https://www.gaodaima.com/tag/work" title="查看更多关于work的文章" target="_blank">work</a>ers=10)
def func_get():
response = requests.get('http://127.0.0.1:5002')
time.sleep(10)
def func_callback():
pass
for 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 ThreadPoolExecutor pool = ThreadPoolExecutor(max_workers=10) pool._work_queue.qsize()
能够应用 _work_queue 拜访到这个外部队列
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：python-的线程池如何获取-work-队列中的消息数量
转载请注明原文链接：python-的线程池如何获取-work-队列中的消息数量
