Pool(数字)#初始化一个Pool类,填写数字设置最大进程池的数量
如果新的请求提交到Pool类以后,会自动创建一个进程池去执行提交的请求
但是如果进程池已经占满,那么请求就会等待,直到池中的进程全部结束才会执行新的请求
下面我放了一些实例
#coding:utf-8frommultiprocessingimportPoolimportos,time,randomdefwork(msg): start_time=time.time() print("开始工作,执行进程号:",msg,os.getpid()) time.sleep(random.randint(1,2))#阻塞线程1-2秒stop_time=time.time() print("结束工作,用时:",stop_time-start_time) if__name__=='__main__': p=Pool(3)#定义一个线程池,设置最大线程池数为3list= ["A","B","C"] foriinlist: p.apply_async(work,(i,))#括号中work是调用函数,i是将list中的元祖传递给目标p.close()#关闭线程池,关闭后p变量不再收到新的请求p.join()#join等待p变量中所有子进程执行完成,必须放在close()后面