Python基础学习 -- 进程锁

简介: Python基础学习 -- 进程锁

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

运行结果:

目录
相关文章
|
3天前
|
Python
python学习3-选择结构、bool值、pass语句
python学习3-选择结构、bool值、pass语句
|
1天前
|
调度 Python
Python多线程、多进程与协程面试题解析
【4月更文挑战第14天】Python并发编程涉及多线程、多进程和协程。面试中,对这些概念的理解和应用是评估候选人的重要标准。本文介绍了它们的基础知识、常见问题和应对策略。多线程在同一进程中并发执行,多进程通过进程间通信实现并发,协程则使用`asyncio`进行轻量级线程控制。面试常遇到的问题包括并发并行混淆、GIL影响多线程性能、进程间通信不当和协程异步IO理解不清。要掌握并发模型,需明确其适用场景,理解GIL、进程间通信和协程调度机制。
6 0
|
1天前
|
机器学习/深度学习 算法 Python
使用Python实现集成学习算法:Bagging与Boosting
使用Python实现集成学习算法:Bagging与Boosting
8 0
|
3天前
|
Python
python学习14-模块与包
python学习14-模块与包
|
3天前
|
Python
python学习12-类对象和实例对象
python学习12-类对象和实例对象
|
3天前
|
数据采集 Python
python学习9-字符串
python学习9-字符串
|
3天前
|
Python
python学习10-函数
python学习10-函数
|
3天前
|
存储 索引 Python
python学习7-元组
python学习7-元组
|
3天前
|
Python
python学习8-集合
python学习8-集合
|
3天前
|
Python
python学习4-内置函数range()、循环结构、循环控制语句、else语句、嵌套循环
python学习4-内置函数range()、循环结构、循环控制语句、else语句、嵌套循环