使用multiprocessing库,通过multiprocessing.Pool设置进程数,即 (processes=3)或者设置你自己的数量,如果池还没有满,就会创建一个新的进程来执行请求。如果池满,请求就会告知先等待,直到池中有进程结束,才会创建新的进程来执行这些请求。

import multiprocessing
def functest(x):
	函数体
if __name__ == "__main__":
    pool = multiprocessing.Pool(processes=3)
    # 动态循环添加进程
    for i in range(3):
	     print("------------------>", i)
	     # Pool().apply_async(要调用的目标,(传递给目标的参数,))
	     # 每次循环将会用空闲出来的子进程去调用目标
	     pool.apply_async(functest, (i,))
	# 或者直接添加,也可调用不同方法
	pool.apply_async(functest, (3,))
    pool.apply_async(functest, ([0,1,2], ))
    pool.apply_async(functest, ({0,3,4}, ))

	pool.close()
    pool.join()
    print("done.")
Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐