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