- 安装
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是回调,没有试过.
最后一句解决内存泄漏.