一、join函数的作用
1、等子进程执行完,主进程再结束
2、将子进程都存储到一个列表,每个子进程都调用一下join方法
if __name__=="__main__": print("我是主线程") s=time.time() a=[2,3,4] b=[] #存储创建好的进程 for i in a: p=Process(target=funa,args=(i,)) p.start() print("程序花费:",time.time()-s)
两个进程间的数据,是不能共享的
二、面向对象启动子进程
1、新建一个类aiyou,传递的参数为Process
2、新建一个run方法,名字必须是run,子进程默认执行的函数
from multiprocessing import Process class aiyou(Process): def __init__(self, name): super().__init__() self.name = name def run(self): print('当前%s子进程正在执行'%self.name) if __name__ == '__main__': p = aiyou('bucuo') p.start()
三、守护进程
1、当没有守护进程的时候,主进程结束后,子进程依旧执行完毕才结束
import time from multiprocessing import Process def funa(n): for i in range(n): time.sleep(1) print("我是a") if __name__=="__main__": print("我是主线程") s=time.time() a=[2,3,4] for i in a: p=Process(target=funa,args=(i,)) p.start() print("程序花费:",time.time()-s)
2、将子进程设置成守护进程(p.daemon=True),主进程一结束,子进程立马结束
import time from multiprocessing import Process def funa(n): for i in range(n): time.sleep(1) print("我是a") if __name__=="__main__": print("我是主线程") s=time.time() a=[2,3,4] for i in a: p=Process(target=funa,args=(i,)) p.daemon=True p.start() print("程序花费:",time.time()-s)
四、进程同步(锁)
1、当创建多个子进程的时候,他们的启动顺序是不一样
import time from multiprocessing import Process from multiprocessing import Lock def funa(): for i in range(10000): print("我是%d开始执行"%i) def funb(l): #l.acquire() funa() #l.release() if __name__=="__main__": print("我是主线程") lock=Lock() for i in range(3): p=Process(target=funb,args=(lock,)) p.start()
运行结果(部分截图),这里执行的顺序就变了
2、枷锁以后,就会按顺序挨个执行
加锁的缺点,使进程失去了异步的功能,优点是:数据更加安全
import time from multiprocessing import Process from multiprocessing import Lock def funa(): for i in range(10000): print("我是%d开始执行"%i) def funb(l): l.acquire() funa() l.release() if __name__=="__main__": print("我是主线程") lock=Lock() for i in range(3): p=Process(target=funb,args=(lock,)) p.start()
运行结果: