Pool

Pool可以提供指定数量的进程，供用户调用，当有新的请求提交到pool中时，如果池还没有满，那么会创建一个新的进程用来执行该请求；但如果池中的进程数已经达到规定最大值，那么该请求就会等待，直到池中有进程结束，才会创建新的进程来执行它。

Pool方法

进程池方法：

apply(func[,args[,kwds]]):阻塞的执行，比如创建一个有3个线程的线程池，当执行时是创建完一个，执行完函数再创建另一个，变成一个线性的执行。

apply_async(func[,args[,kwds[,callback]]]):它是非阻塞执行，同时创建3个线程的线程池，同时执行，只要有一个执行完立刻放回池子待下一个执行，并行的执行。

close():关闭pool,使其不再接受新的任务。

terminate():结束工作进程，不在处理未完成的任务。

join():主进程阻塞，等待子进程的退出，join方法要在close或terminate之后使用。

import multiprocessing
import os
import time
def work(n):print('run work (%s),work id %s'%(n,os.getpid()))time.sleep(5)print('work (%s) stop,work id %s'%(n,os.getpid()))
if __name__ == '__main__':print('Parent process %s.'%os.getpid())p = multiprocessing.Pool(3)for i in range(5):p.apply_async(work,args=(i,))p.close()p.join()

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！