# 一个简单的 demo
def some_func(arg):
# does some heavy lifting
# outputs some results
time.sleep(10)
return 0
from concurrent.futures import ThreadPoolExecutor
import time
with ThreadPoolExecutor(max_workers = 1024) as executor:
for arg in range(10000):
future = executor.submit(some_func, arg)
print(len(executor._threads))
简单做了下压力测试,发现 windows 系统上的 python 线程并发负载还可以,一两千个线程还是能 handle 的。
但是发现了一个蛋疼的问题,比如如果你要提高负载能力,比如你想要让程序能同时负载 1000 个并发连接。那么线程池在触发并完成线程后,并不会自动释放资源。我原以为线程池有一些机制在,比如一小时闲置的话就会自动摧毁占用的线程,现在看来似乎不是这样的,一旦申请以后线程就一直在这里了。
有什么办法做改进吗?这些线程即使不用也在这里趴着,一方面吃内存,另一方面系统允许的最大线程数又是有限的,被大量占用。