- 安装
pip install threadpool
- 使用
pool = ThreadPool(count) requests = makeRequests(method, list_of_args, callback) [pool.putRequest(req) for req in requests] pool.wait() # 防止内存泄漏 pool.dismissWorkers(count, do_join=True)
其中:
method是执行函数.
list_of_args是参数,数量同count.注意不会pop.如果需要,自己pop或者用一个临时的list.
callback是回调,没有试过.
最后一句解决内存泄漏.