import multiprocessing
(资料图片)
创建进程池(pool)
pool = multiprocessing.Pool(num)
num:创建处理进程数量
添加进程
进程池只会创建上述定义的进程数量,多的进程任务添加到任务列表
pool.apply_async(target,args, kwds)
target:传入线程函数
args:传递函数参数(没有可忽略,传递加括号,结束加逗号)如args=(1,)
kwds:指定函数传参(字典)
进程池用完处理
pool.close()关闭进程池
pool.join()等待任务结束后释放资源(阻塞)
进程池间通信
创建队列
q = multiprocessing.Manager().Queue()
放入数据
q.put(要放入的数据)
取出数据
q.get(True)阻塞(默认)
q.get(False)不阻塞
广告
X 关闭
广告
X 关闭