from concurrent.futures import ThreadPoolExecutor
import time
all_task = []
thread_pool_count = 0
def abc(i,j):
time.sleep(10)
thread_pool = ThreadPoolExecutor(10)
i = 0
j = 0
all_task.append(thread_pool.submit(
abc,i,j
))
all_task.append(thread_pool.submit(
abc,j
))
while True:
for future in all_task:
if future.done():
all_task.remove(future)
thread_pool_count = len(all_task)
print(thread_pool_count)
至此得到线程池正在工作线程个数。
如果需要与进程通信,参考:https://mohen.blog.csdn.net/article/details/115075004
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。