【第50天】python全栈从入门到放弃

2019-08-09  本文已影响0人  36140820cbfd

1.并行,并发,阻塞,非阻塞,同步,异步的理解

并行:指两件或多件事情,在同一时间点同时执行
并发:指两件或多件事情,在同一时间间隔内同时执行
阻塞与非阻塞:程序运行过程中如果遇到input,或者recv(1024)需要等待用户输入,需要接收信息才能进行下一步,这个过程就叫做阻塞,否则就是非阻塞。
同步:一个任务的完成需要事件A和事件B都完成,但是事件B只有等到事件A完成才能开启自己。
异步:事件A和事件B相互独立,互不干扰。

2.多个子进程的开启

子进程的异步

代码块:同步
from multiprocessing import Process
import random
import time

def func1(i):
    print(i)


if __name__=='__main__':
    lst=list(range(50))
    for i in lst:
        p1=Process(target=func1,args=(i,))
        p1.start()  #开启p1进程

    time.sleep(3)
    res=random.choice(lst)

子进程的同步

代码块
from multiprocessing import Process
import random
import time

def func1(i):
    print(i)


if __name__=='__main__':
    lst=list(range(50))
    for i in lst:
        p1=Process(target=func1,args=(i,))
        p1.start()  #开启p1进程
        p1.join()   #join()   异步变同步,当前的执行完,才会执行下一个,这就是同步。

    time.sleep(3)
    res=random.choice(lst)

3. 多个子进程无法共享内存,会报错

代码块
from multiprocessing import Process
import random
import time

def func1(i):
    global n
    print(i,n)


if __name__=='__main__':
    n=666   #这里n是全局变量
    lst=list(range(50))
    for i in lst:
        p1=Process(target=func1,args=(i,))
        p1.start()  #开启p1进程
        # p1.join()   #join()   异步变同步,当前的执行完,才会执行下一个,这就是同步。

    time.sleep(3)
    res=random.choice(lst)

4. 开启子进程的方式

第一种:

代码块
from multiprocessing import Process
import random
import time
import os

# os.getpid()获取的是当前进程自己的pid
# os.getppid()获取的是当前进程的父进程的pid

def func1(i):
    print('我是儿子进程,我的进程号是%d,我爸爸的进程号是%d'%(os.getpid(),os.getppid()))

if __name__=='__main__':
    p=Process(target=func1,args=('wangsiyu',))
    p.name='son of process'  #给开启的子进程命名
    p.start()
    print('我是爸爸进程,我的进程号是%s'%os.getpid())

# #res:我是爸爸进程,我的进程号是14128
# 我是儿子进程,我的进程号是9888,我爸爸的进程号是14128

用继承来开启进程

代码块
from multiprocessing import Process
import random
import time
import os

class MyProcess(Process):
    def __init__(self):
        super(MyProcess, self).__init__()#  执行父类的__init__方法

    def run(self):
        print('这是以继承类的方式开启的子进程,他的名字是%s'%self.name)

if __name__ == '__main__':
    p1 = MyProcess()   #实例化对象
    p1.start()# 是指,解释器告诉操作系统,去帮我开启一个进程,   就绪状态
    # p1.run()# 告诉操作系统,现在马上帮我执行这个子进程           执行

5 如何开启多个子进程

代码块
def func(i):
    time.sleep(1)
    print('这里是儿子%s进程,儿子自己的pid是%s,儿子的父进程的pid是%s'%(i,os.getpid(),os.getppid()))

# os.getpid()获取的是当前进程自己的pid
# os.getppid()获取的是当前进程的父进程的pid
if __name__ == '__main__':
    for i in range(2):
        p = Process(target=func,args=(i,))# 实例化一个进程对象
        p.start()# 开启一个子进程,因为有range(2)循环,所以可以开启多个子进程
    print('这里是父亲进程,父进程自己的pid是:%s,父亲的父亲的pid是%s'%(os.getpid(),os.getppid()))

5. 利用p.is_alive()判断进程是否活着,用p.terminate()杀死进程

代码块

from multiprocessing import Process
import time


def func():
    time.sleep(1)
    print(123)


if __name__ == '__main__':
    p = Process(target=func)
    p.start()

    print('子进程是否还活着?', p.is_alive())
    p.terminate()  # 杀死p进程,让解释器告诉操作系统,请杀掉p进程。
    time.sleep(2)
    print('子进程是否还活着?', p.is_alive())
    # 返回一个bool值,如果返回True,代表进程还活着,如果返回False,代表子进程死了

# p.is_alive() 判断p进程是否还活着
# p.terminate() 杀死p进程

6. 守护进程

什么是守护进程

代码块
from multiprocessing import Process
import time

def func():
    time.sleep(5)
    print('这里是儿子哦')

if __name__ == '__main__':
    p = Process(target=func)
    p.daemon = True # 将p进程设置为守护进程,必须要在start之前设置
    p.start()
    time.sleep(1)
    print('这是爸爸')
# 总结一下:
#     守护进程:跟随着父进程的代码执行结束,守护进程就结束

守护进程会随着爸爸进程的结束结束,并且不能自己开子进程,会报错

代码块
from multiprocessing import Process
import time

def func1():
    print('这里是孙子')

def func():
    p = Process(target=func1)
    p.start()
    time.sleep(5)
    print('这里是儿子哦')

if __name__ == '__main__':
    p = Process(target=func)
    p.daemon = True # 将p进程设置为守护进程,必须要在start之前设置
    p.start()
    time.sleep(1)
    print('这是爸爸')
    # 守护进程:不允许开启子进程

守护进程的用法

代码块
from multiprocessing import Process
import time


def func():
    for i in range(10):
        print(time.strftime('%H:%M:%S'))
        time.sleep(1)

if __name__ == '__main__':
    p = Process(target=func)
    p.daemon = True # 将p进程设置为守护进程,必须要在start之前设置
    p.start()
    time.sleep(5)
    print('这是爸爸')

7. 进程的常用属性

代码块

from multiprocessing import Process
import time
import os

def func():
    print('这里是儿子,儿子的pid是%s'%(os.getpid()))

if __name__ == '__main__':
    p = Process(target=func)
    p.start()
    p.name = 'alex'
    print('儿子的名字是%s'%p.name)
    print('儿子的pid是%s'%p.pid)
    print('儿子是不是守护进程?',p.daemon)


8. start(),join(),daemon

代码块
from multiprocessing import Process
import time

def func():
    for i in range(100):
        time.sleep(0.01)
        print('儿子在这里')

if __name__ == '__main__':
    p = Process(target=func)
    p.start()
    p.join()# 是让主进程等待子进程执行完。  现象:主进程执行到这句话,主进程阻塞住,等待子进程执行
    # time.sleep(1)
    for i in range(100):
        time.sleep(0.01)
        print('爸爸在这里')

# 开启一个正常的子进程,父进程会等待子进程结束后,父进程也就是程序才结束
# p.join()# 是让主进程等待子进程执行完。  现象:主进程执行到这句话,主进程阻塞住,等待子进程执行
# 如何把父进程和子进程之间的关系变为同步或者异步?
# 父进程执行join,就会变成同步,不执行join,父进程和子进程就是异步的关系
# join必须放在start()后边,daemon必须放在shart()前边

9.今天的知识总结

代码块
from multiprocessing import Process

      获取当前进程的pid号,os.getpid()
      获取当前进程的父进程的pid号,os.getppid()

      开启子进程的方式:
         1 p = Process(target=func,args=(,))
           target: 是子进程要执行的任务
           args:是父进程给子进程传递的参数
         2 自定义类,去继承Process

      进程的方法:
          p.start()开启子进程,底层调用的是p.run()


    2 进程的两种开启方法
      (1) p = Process(target=None,args(,))
      (2) 自定义类,继承Process父类

    3 进程的常用方法
      (1) start()  开启一个子进程
      (2) join()   异步变同步(就是让父进程停留在join这句话,等待子进程执行结束,父进程再继续执行)
      (3) is_alive() 判断进程是否活着
      (4) terminate()   杀死一个进程


    4 进程的常用属性
       (1) p.name =    给p进程一个名字
       (2) p.pid       返回p进程的pid
       (3) p.daemon = True   将p进程设置为守护进程。(True为守护进程,False为普通进程)
           守护进程的两个特点:
              守护进程会随着父进程的结束而结束
              守护进程不能再创建子进程(不能要孩子)

别跑,点个赞再走
上一篇 下一篇

猜你喜欢

热点阅读