定义一个函数,使用不同的参数同时执行10次
import multiprocessing
def my_fun(para1, para2):
return para1 + para2
paras = ((i, i + 1) for i in range(10)) # 这里每个任务需要两个参数,因此为长度为10的二元元组(生成器)
threads = 10
p = multiprocessing.Pool(processes=threads) # processes为最大线程数
res = p.starmap_async(my_fun, paras).get()
p.close() # 关闭进程池,不能再向进程池中添加进程
p.join()