关于python:python-的线程池如何获取-work-队列中的消息数量

31次阅读

共计 558 个字符,预计需要花费 2 分钟才能阅读完成。

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

from concurrent.futures import ThreadPoolExecutor
from loguru import logger
import requests
import time

pool = ThreadPoolExecutor(max_workers=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 拜访到这个外部队列

正文完
 0