文章/答案/技术大牛

发布

社区首页 >问答首页 >检查`concurrent.futures.ThreadPoolExecutor`

问检查`concurrent.futures.ThreadPoolExecutor`
EN

Stack Overflow用户

提问于 2014-08-25 01:10:56

回答 2查看 12.3K关注 0票数 22

我有一个直播的concurrent.futures.ThreadPoolExecutor。我想检查一下它的状态。我想知道有多少线程，有多少正在处理任务，哪些任务，有多少是空闲的，哪些任务在队列中。我怎么才能找到这些东西呢？

python

concurrency

introspection

concurrent.futures

回答 2

Stack Overflow用户

回答已采纳

发布于 2014-08-25 02:23:42

可以看到Pool和pending工作项队列的一些可见性。要找出可用的内容，可以打印poolx.__dict__以查看其结构。阅读ThreadPool代码，它非常好用：concurrent.futures.thread

下面的代码创建一个只有一个线程的池。然后，它创建两个作业:一个休眠3秒，另一个立即返回。然后打印池中挂起的工作项的数量。

然后，我们从工作队列中打印出项目。在本例中，一个线程已经在执行time.sleep(3)函数，因此该函数不在队列中。打印带有args [0]和kwargs {}的函数sleep，因为这是池要运行的下一个工作项。

称赞@dano的非破坏性队列洞察力，以及@abarnert。

来源

import concurrent.futures, time

poolx = concurrent.futures.ThreadPoolExecutor(max_workers=1)
poolx.submit(time.sleep, 3)
poolx.submit(time.sleep, 0)   # very fast

print('pending:', poolx._work_queue.qsize(), 'jobs')
print('threads:', len(poolx._threads))
print()

# TODO: make thread safe; work on copy of queue?
print('Estimated Pending Work Queue:')
for num,item in enumerate(poolx._work_queue.queue):
    print('{}\t{}\t{}\t{}'.format(
        num+1, item.fn, item.args, item.kwargs,
        ))

poolx.shutdown(wait=False)

输出

pending: 1 jobs
threads: 1

Pending Work Queue:
1   <built-in function sleep>   (0,)    {}

票数 14

Stack Overflow用户

发布于 2019-07-25 02:00:17

寻找pending期货的方法也不是很干净和可靠，但我是这样做的：

if 'state=pending' in str(future):
    logger.debug('PENDING')
elif future.running():
    logger.debug('RUNNING')
elif future.cancelled():
    logger.debug('CANCELLED')
elif future.exception():
    logger.debug('EXCEPTION')
elif future.done():
    logger.debug('DONE')

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/25474204

复制

相似问题

问检查`concurrent.futures.ThreadPoolExecutor`
EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问检查`concurrent.futures.ThreadPoolExecutor`EN

回答 2

Stack Overflow用户

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问检查`concurrent.futures.ThreadPoolExecutor`
EN