首页 > > 网络编程 > 其它 >

python 之并发编程（开启子进程的两种方式，进…

2019-07-24 09:25:43来源：博客园阅读 ()

第九章并发编程

同一个程序执行多次是多个进程

import time
import os
?
print('爹是：',os.getppid())      #父进程PID，(pycharm)
print('me是: ',os.getpid())      #3748 14648
time.sleep(500)

9.1 开启子进程的两种方式

服务端目标： 1、不间断地提供服务 2、服务端要支持高并发+高性能

一个进程在运行过程中开启了子进程（如nginx开启多进程，os.fork,subprocess.Popen等）

父进程发起请求，操作系统创建子进程

方式一：

from multiprocessing import Process
import time
import os
def task(name):
    print('%s is running' %name)
    time.sleep(3)
    print('%s has done' %name)
    print('爹是：', os.getppid()) #me是:  13892
    print('me是: ', os.getpid())  #me是:  7492
?
if __name__ == '__main__':                  # windows系统，开启子进程的操作一定要放到这下面
    p=Process(target=task,args=('egon',))     # p=Process(target=task,kwargs={'name':'egon'})
    p.start() # 向操作系统发送请求，操作系统会申请内存空间，然后把父进程的数据拷贝给子进程，作为子进程的初始状态
    print('me是: ', os.getpid())  #me是:  13892
    print('======主')#======主 egon is running egon has done

target 表示调用对象，即子进程要执行的任务
args 指定为target函数传位置参数，是一个元组形式，必须有逗号
kwargs 表示调用对象的字典,kwargs={'name':'egon','age':18}
p.start() 启动进程，并调用该子进程中的p.run()

方式二：

from multiprocessing import Process
import time
?
class MyProcess(Process):
    def __init__(self,name):
        super(MyProcess,self).__init__()
        self.name=name
?
    def run(self):
        print('%s is running' %self.name)
        time.sleep(3)
        print('%s has done' %self.name)
?
if __name__ == '__main__':
    p=MyProcess('egon')
    p.start()
    print('主')  #主  egon is running  egon has done

p.run():进程启动时运行的方法，正是它去调用target指定的函数，我们自定义类的类中一定要实现该方法

9.2 进程之间内存空间隔离

from multiprocessing import Process
import time
x=1000
def task():
    time.sleep(3)
    global x
    x=0
    print('儿子死啦',x)
?
?
if __name__ == '__main__':
    print(x)
    p=Process(target=task)
    p.start()
    time.sleep(5)
    print(x)    #1000    儿子死啦 0    1000

9.3 父进程等待子进程结束

from multiprocessing import Process
import time
x=1000
def task():
    time.sleep(3)
    global x
    x=0
    print('儿子死啦',x)
?
if __name__ == '__main__':
    p=Process(target=task)
    p.start()
?
    p.join() # 让父亲在原地等
    print(x)
from multiprocessing import Process
import time
x=1000
def task(n):
    print('%s is runing' %n)
    time.sleep(n)
?
if __name__ == '__main__':
    start_time=time.time()
    p_l=[]
    for i in range(1,4):
        p=Process(target=task,args=(i,))
        p_l.append(p)
        p.start()
?
    for p in p_l:                       #1 is runing
        p.join()                        #3 is runing
    print('主',(time.time() - start_time)) #2 is runing    主  3.112313

9.4 进程对象的其他属性

p.terminate():强制终止进程p，不会进行任何清理操作，如果p创建了子进程，该子进程就成了僵尸进程，使用该方法需要特别小心这种情况。如果p还保存了一个锁那么也将不会被释放，进而导致死锁
p.is_alive():如果p仍然运行，返回True
p.join([timeout]):主线程等待p终止（强调：是主线程处于等的状态，而p是处于运行的状态）。timeout是可选的超时时间，强调: p.join只能 join住start开启的进程，而不能join住run开启的进程
p.pid：进程的pid

from multiprocessing import Process
import time,os
x=1000
def task(n):
    print('%s is runing self:%s parent:%s' %(n,os.getpid(),os.getppid()))#self:13032 parent:9136
    time.sleep(3)
?
if __name__ == '__main__':
    p1=Process(target=task,args=(1,),name='任务1')#不指定name,p1.name是process-1
    p1.start()
          
    print(p1.pid)       # 13032 没有p1.ppid
    print(p1.name)      # 任务1
    p1.terminate()      # 向操作系统提交进程终止 
    p1.join()
    print(p1.is_alive()) # False
?
    print('主',os.getpid())# 主 9136