Pool进程池

进程池与Process区别, 主进程不会等着进程池结束才结束,但是process创建子进程,

进程池避免了重复创建进程的过程

from multiprocessing import Pool
import time
import os


def work1():
for i in range(4):
print("-----work1=%d-----"%i)

def work(num):
for i in range(4):
print("===pid=%d==num=%d"%(os.getpid(), num))


if __name__ == "__main__":
#表示进程池中对多有三个进程一起执行
pool =Pool(3)

for i in range(5):
print("----%d----"%i)
#向进程池添加任务
#如果添加的任务数量超过了 进程池中的个数的话,那么不会导致添加不进入
#添加到进程的任务 如果还没有被执行的话 那么此时 他们会等待进程池中的进程完成一个任务之后, 会自动的去用刚刚的那个进程 完成当前的新任务
pool.apply_async(work,(i,))
pool.apply_async(work1)
print("----%d----" % i)

pool.close()# 关闭进程池 相当于 不能够添加新任务了
pool.join()#如果没有join(), 会导致进程池中的任务不会执行

Pool进程池

上一篇:【设计模式】原型模式 ( 概念简介 | 使用场景 | 优缺点 | 基本用法 )


下一篇:智能消息服务-数字短信使用FAQ