提供了编程的基础技术教程

zl程序教程

您现在的位置是：首页 >  Python

当前栏目

Python基础学习 -- 进程锁

Python 进程 基础 学习
2023-03-14 22:46:12 时间

一、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()


运行结果（部分截图），这里执行的顺序就变了

0a2653c851af460fa595bd959398a8f1.png


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()


运行结果：

0eacb84100b54626af849e6b562bf92a.png

相关文章