网络编程
网络编程
澳门电子游戏平台网站全python3全栈开发-并发编程,多进程的基本操作
网络编程 2019-11-25 17:45

大器晚成 、multiprocessing模块介绍

    python中的十六线程不能使用多核优势,假使想要足够地行使多核CPU的财富(os.cpu_count()查看卡塔 尔(英语:State of Qatar),在python中许多动静需求运用多进度。Python提供了multiprocessing。
    multiprocessing模块用来开启子进度,并在子进度中实施我们定制的职责(比方函数卡塔 尔(阿拉伯语:قطر‎,该模块与四线程模块threading的编制程序接口相像。

  multiprocessing模块的效果与利益多多:帮忙子进度、通讯和分享数据、实行相当的小器晚成款式的一齐,提供了Process、Queue、Pipe、Lock等零构件。

    要求再度重申的有个别是:与线程不一致,进度未有其余分享状态,进程订正的多少,退换只限于该进程内。

python并发编程之多进度

翻阅目录

  • 风华正茂 multiprocessing模块介绍
  • 二 Process类的牵线
  • 三 Process类的应用
  • 四 守护进程

二、 Process类的牵线

    创制进程的类

Process([group [, target [, name [, args [, kwargs]]]]]),由该类实例化得到的对象,表示一个子进程中的任务(尚未启动)

强调:
1. 需要使用关键字的方式来指定参数
2. args指定的为传给target函数的位置参数,是一个元组形式,必须有逗号

    参数介绍:

澳门电子游戏平台网站全 1澳门电子游戏平台网站全 2

#group参数未使用,值始终为None
#target表示调用对象,即子进程要执行的任务
#args表示调用对象的位置参数元组,args=(1,2,'duoduo',)
#kwargs表示调用对象的字典,kwargs={'name':'duoduo','age':18}
#name为子进程的名称

参数详明

  艺术介绍:

澳门电子游戏平台网站全 3澳门电子游戏平台网站全 4

#p.start():启动进程,并调用该子进程中的p.run() 
#p.run():进程启动时运行的方法,正是它去调用target指定的函数,我们自定义类的类中一定要实现该方法  
#p.terminate():强制终止进程p,不会进行任何清理操作,如果p创建了子进程,该子进程就成了僵尸进程,使用该方法需要特别小心这种情况。
如果p还保存了一个锁那么也将不会被释放,进而导致死锁
#p.is_alive():如果p仍然运行,返回True
#p.join([timeout]):主线程等待p终止(强调:是主线程处于等的状态,而p是处于运行的状态)。
#timeout是可选的超时时间,需要强调的是,p.join只能join住start开启的进程,而不能join住run开启的进程  

方法介绍详整

澳门电子游戏平台网站全python3全栈开发-并发编程,多进程的基本操作。    品质介绍:

澳门电子游戏平台网站全 5澳门电子游戏平台网站全 6

#p.daemon:默认值为False,如果设为True,代表p为后台运行的守护进程,当p的父进程终止时,p也随之终止,并且设定为True后,p不能创建自己的新进程,必须在p.start()之前设置
#p.name:进程的名称
#p.pid:进程的pid
#p.exitcode:进程在运行时为None、如果为–N,表示被信号N结束(了解即可)
#p.authkey:进程的身份验证键,默认是由os.urandom()随机生成的32字符的字符串。
#这个键的用途是为涉及网络连接的底层进程间通信提供安全性,这类连接只有在具有相同的身份验证键时才能成功(了解即可)

性格介绍详明

意气风发 multiprocessing模块介绍

python中的四线程无法运用多核优势,要是想要丰盛地采用多核CPU的能源(os.cpu_澳门电子游戏平台网站全,count,在python中山大学部分境况要求利用多进程。Python提供了multiprocessing。
multiprocessing模块用来开启子进度,并在子进程中履行大家定制的职责,该模块与多线程模块threading的编制程序接口相像。

 multiprocessing模块的效率多多:扶助子进度、通讯和分享数据、实施不风姿浪漫式样的同步,提供了Process、Queue、Pipe、Lock等零零部件。

内需再行重申的少数是:与线程分裂,进度没有别的分享状态,进度校勘的多少,更改只限于该进程内。

三 、Process类的应用

当心:在windows中Process()必得置于# if __name__ == '__main__':下

澳门电子游戏平台网站全 7澳门电子游戏平台网站全 8

Since Windows has no fork, the multiprocessing module starts a new Python process and imports the calling module. 
If Process() gets called upon import, then this sets off an infinite succession of new processes (or until your machine runs out of resources). 
This is the reason for hiding calls to Process() inside

if __name__ == "__main__"
since statements inside this if-statement will not get called upon import.
由于Windows没有fork,多处理模块启动一个新的Python进程并导入调用模块。 
如果在导入时调用Process(),那么这将启动无限继承的新进程(或直到机器耗尽资源)。 
这是隐藏对Process()内部调用的原,使用if __name__ == “__main __”,这个if语句中的语句将不会在导入时被调用。

详细降解

始建并开启子进度的二种方法

澳门电子游戏平台网站全 9澳门电子游戏平台网站全 10

#开进程的方法一:
import time
import random
from multiprocessing import Process
def run(name):
    print('%s run' %name)
    time.sleep(random.randrange(1,5))
    print('%s run end' %name)

p1=Process(target=run,args=('qian',)) #必须加,号
p2=Process(target=run,args=('ze',))
p3=Process(target=run,args=('liang',))
p4=Process(target=run,args=('duoduo',))

p1.start()
p2.start()
p3.start()
p4.start()
print('主线程')

开子进程第生机勃勃种艺术

澳门电子游戏平台网站全 11澳门电子游戏平台网站全 12

#开子进程的方法二:
import time
import random
from multiprocessing import Process

class Fun(Process):
    def __init__(self,name):
        super().__init__()
        self.name=name
    def run(self):
        print('%s run' %self.name)

        time.sleep(random.randrange(1,5))
        print('%s run end' %self.name)

p1=Fun('qian')
p2=Fun('ze')
p3=Fun('liang')
p4=Fun('duoduo')

p1.start() #start会自动调用run
p2.start()
p3.start()
p4.start()
print('主线程')

开子进度第两种办法

进程一直的内部存款和储蓄器空间是隔绝的

澳门电子游戏平台网站全 13澳门电子游戏平台网站全 14

from multiprocessing import Process
n=100 #在windows系统中应该把全局变量定义在if __name__ == '__main__'之上就可以了
def work():
    global n
    n=0
    print('子进程内: ',n)

if __name__ == '__main__':
    p=Process(target=work)
    p.start()
    print('主进程内: ',n)

表明父进程和子进程内存空间是隔开的

Process对象的join方法

澳门电子游戏平台网站全 15澳门电子游戏平台网站全 16

from multiprocessing import Process
import time
import random

class Fun(Process):
    def __init__(self,name):
        self.name=name
        super().__init__()
    def run(self):
        print('%s is run' %self.name)
        time.sleep(random.randrange(1,3))
        print('%s is run end' %self.name)

p=run('duoduo')
p.start()
p.join() #等待p停止
print('开始')

主进度等子进度运维甘休

澳门电子游戏平台网站全 17澳门电子游戏平台网站全 18

from multiprocessing import Process
import time
import random
def piao(name):
    print('%s is piaoing' %name)
    time.sleep(random.randint(1,3))
    print('%s is piao end' %name)

p1=Process(target=piao,args=('egon',))
p2=Process(target=piao,args=('alex',))
p3=Process(target=piao,args=('yuanhao',))
p4=Process(target=piao,args=('wupeiqi',))

p1.start()
p2.start()
p3.start()
p4.start()

#有的同学会有疑问:既然join是等待进程结束,那么我像下面这样写,进程不就又变成串行的了吗?
#当然不是了,必须明确:p.join()是让谁等?
#很明显p.join()是让主线程等待p的结束,卡住的是主线程而绝非进程p,

#详细解析如下:
#进程只要start就会在开始运行了,所以p1-p4.start()时,系统中已经有四个并发的进程了
#而我们p1.join()是在等p1结束,没错p1只要不结束主线程就会一直卡在原地,这也是问题的关键
#join是让主线程等,而p1-p4仍然是并发执行的,p1.join的时候,其余p2,p3,p4仍然在运行,等#p1.join结束,可能p2,p3,p4早已经结束了,这样p2.join,p3.join.p4.join直接通过检测,无需等待
# 所以4个join花费的总时间仍然是耗费时间最长的那个进程运行的时间
p1.join()
p2.join()
p3.join()
p4.join()

print('主线程')


#上述启动进程与join进程可以简写为
# p_l=[p1,p2,p3,p4]
# 
# for p in p_l:
#     p.start()
# 
# for p in p_l:
#     p.join()

join的生龙活虎对误区

Process对象的任何方式或质量(掌握卡塔 尔(阿拉伯语:قطر‎

澳门电子游戏平台网站全 19澳门电子游戏平台网站全 20

#进程对象的其他方法一:terminate,is_alive
from multiprocessing import Process
import time
import random

class Fun(Process):
    def __init__(self,name):
        self.name=name
        super().__init__()

    def run(self):
        print('%s is running' %self.name)
        time.sleep(random.randrange(1,5))
        print('%s is running end' %self.name)

p1=Fun('duoduo')
p1.start()
p1.terminate()#关闭进程,不会立即关闭,所以is_alive立刻查看的结果可能还是存活
print(p1.is_alive()) #结果为True

print('开始')
time.sleep(1)
print(p1.is_alive()) #结果为False

terminate(关闭进度),is_alive(进度是还是不是终止卡塔 尔(阿拉伯语:قطر‎

澳门电子游戏平台网站全 21澳门电子游戏平台网站全 22

from multiprocessing import Process
import time
import random
class Fun(Process):
    def __init__(self,name):
        # self.name=name
        # super().__init__() #Process的__init__方法会执行
        #self.name=Fun-1,
#所以加到这里,会覆盖我们的self.name=name

        #为我们开启的进程设置名字的做法
        super().__init__()
        self.name=name

    def run(self):
        print('%s is running' %self.name)
        time.sleep(random.randrange(1,3))
        print('%s is running end' %self.name)


if __name__=="__main__":
    p=Fun('duoduo')
    p.start()
    print('开始',p.name)
    print(p.pid) #查看pid

name和pid

丧尸进度与孤儿进度(通晓卡塔 尔(阿拉伯语:قطر‎

澳门电子游戏平台网站全 23澳门电子游戏平台网站全 24

参考博客:http://www.cnblogs.com/Anker/p/3271773.html

一:僵尸进程(有害)
  僵尸进程:一个进程使用fork创建子进程,如果子进程退出,而父进程并没有调用wait或waitpid获取子进程的状态信息,那么子进程的进程描述符仍然保存在系统中。这种进程称之为僵死进程。详解如下

我们知道在unix/linux中,正常情况下子进程是通过父进程创建的,子进程在创建新的进程。子进程的结束和父进程的运行是一个异步过程,即父进程永远无法预测子进程到底什么时候结束,如果子进程一结束就立刻回收其全部资源,那么在父进程内将无法获取子进程的状态信息。

因此,UNⅨ提供了一种机制可以保证父进程可以在任意时刻获取子进程结束时的状态信息:
1、在每个进程退出的时候,内核释放该进程所有的资源,包括打开的文件,占用的内存等。但是仍然为其保留一定的信息(包括进程号the process ID,退出状态the termination status of the process,运行时间the amount of CPU time taken by the process等)
2、直到父进程通过wait / waitpid来取时才释放. 但这样就导致了问题,如果进程不调用wait / waitpid的话,那么保留的那段信息就不会释放,其进程号就会一直被占用,但是系统所能使用的进程号是有限的,如果大量的产生僵死进程,将因为没有可用的进程号而导致系统不能产生新的进程. 此即为僵尸进程的危害,应当避免。

  任何一个子进程(init除外)在exit()之后,并非马上就消失掉,而是留下一个称为僵尸进程(Zombie)的数据结构,等待父进程处理。这是每个子进程在结束时都要经过的阶段。如果子进程在exit()之后,父进程没有来得及处理,这时用ps命令就能看到子进程的状态是“Z”。如果父进程能及时 处理,可能用ps命令就来不及看到子进程的僵尸状态,但这并不等于子进程不经过僵尸状态。  如果父进程在子进程结束之前退出,则子进程将由init接管。init将会以父进程的身份对僵尸状态的子进程进行处理。

二:孤儿进程(无害)

  孤儿进程:一个父进程退出,而它的一个或多个子进程还在运行,那么那些子进程将成为孤儿进程。孤儿进程将被init进程(进程号为1)所收养,并由init进程对它们完成状态收集工作。

  孤儿进程是没有父进程的进程,孤儿进程这个重任就落到了init进程身上,init进程就好像是一个民政局,专门负责处理孤儿进程的善后工作。每当出现一个孤儿进程的时候,内核就把孤 儿进程的父进程设置为init,而init进程会循环地wait()它的已经退出的子进程。这样,当一个孤儿进程凄凉地结束了其生命周期的时候,init进程就会代表党和政府出面处理它的一切善后工作。因此孤儿进程并不会有什么危害。

我们来测试一下(创建完子进程后,主进程所在的这个脚本就退出了,当父进程先于子进程结束时,子进程会被init收养,成为孤儿进程,而非僵尸进程),文件内容

import os
import sys
import time

pid = os.getpid()
ppid = os.getppid()
print 'im father', 'pid', pid, 'ppid', ppid
pid = os.fork()
#执行pid=os.fork()则会生成一个子进程
#返回值pid有两种值:
#    如果返回的pid值为0,表示在子进程当中
#    如果返回的pid值>0,表示在父进程当中
if pid > 0:
    print 'father died..'
    sys.exit(0)

# 保证主线程退出完毕
time.sleep(1)
print 'im child', os.getpid(), os.getppid()

执行文件,输出结果:
im father pid 32515 ppid 32015
father died..
im child 32516 1

看,子进程已经被pid为1的init进程接收了,所以僵尸进程在这种情况下是不存在的,存在只有孤儿进程而已,孤儿进程声明周期结束自然会被init来销毁。


三:僵尸进程危害场景:

  例如有个进程,它定期的产 生一个子进程,这个子进程需要做的事情很少,做完它该做的事情之后就退出了,因此这个子进程的生命周期很短,但是,父进程只管生成新的子进程,至于子进程 退出之后的事情,则一概不闻不问,这样,系统运行上一段时间之后,系统中就会存在很多的僵死进程,倘若用ps命令查看的话,就会看到很多状态为Z的进程。 严格地来说,僵死进程并不是问题的根源,罪魁祸首是产生出大量僵死进程的那个父进程。因此,当我们寻求如何消灭系统中大量的僵死进程时,答案就是把产生大 量僵死进程的那个元凶枪毙掉(也就是通过kill发送SIGTERM或者SIGKILL信号啦)。枪毙了元凶进程之后,它产生的僵死进程就变成了孤儿进 程,这些孤儿进程会被init进程接管,init进程会wait()这些孤儿进程,释放它们占用的系统进程表中的资源,这样,这些已经僵死的孤儿进程 就能瞑目而去了。

四:测试
#1、产生僵尸进程的程序test.py内容如下

#coding:utf-8
from multiprocessing import Process
import time,os

def run():
    print('子',os.getpid())

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

    print('主',os.getpid())
    time.sleep(1000)


#2、在unix或linux系统上执行
[root@vm172-31-0-19 ~]# python3  test.py &
[1] 18652
[root@vm172-31-0-19 ~]# 主 18652
子 18653

[root@vm172-31-0-19 ~]# ps aux |grep Z
USER       PID %CPU %MEM    VSZ   RSS TTY      STAT START   TIME COMMAND
root     18653  0.0  0.0      0     0 pts/0    Z    20:02   0:00 [python3] <defunct> #出现僵尸进程
root     18656  0.0  0.0 112648   952 pts/0    S+   20:02   0:00 grep --color=auto Z

[root@vm172-31-0-19 ~]# top #执行top命令发现1zombie
top - 20:03:42 up 31 min,  3 users,  load average: 0.01, 0.06, 0.12
Tasks:  93 total,   2 running,  90 sleeping,   0 stopped,   1 zombie
%Cpu(s):  0.0 us,  0.3 sy,  0.0 ni, 99.7 id,  0.0 wa,  0.0 hi,  0.0 si,  0.0 st
KiB Mem :  1016884 total,    97184 free,    70848 used,   848852 buff/cache
KiB Swap:        0 total,        0 free,        0 used.   782540 avail Mem 

  PID USER      PR  NI    VIRT    RES    SHR S %CPU %MEM     TIME+ COMMAND                                                                                                                                        
root      20   0   29788   1256    988 S  0.3  0.1   0:01.50 elfin                                                                                                                      


#3、
等待父进程正常结束后会调用wait/waitpid去回收僵尸进程
但如果父进程是一个死循环,永远不会结束,那么该僵尸进程就会一直存在,僵尸进程过多,就是有害的
解决方法一:杀死父进程
解决方法二:对开启的子进程应该记得使用join,join会回收僵尸进程
参考python2源码注释
class Process(object):
    def join(self, timeout=None):
        '''
        Wait until child process terminates
        '''
        assert self._parent_pid == os.getpid(), 'can only join a child process'
        assert self._popen is not None, 'can only join a started process'
        res = self._popen.wait(timeout)
        if res is not None:
            _current_process._children.discard(self)

join方法中调用了wait,告诉系统释放僵尸进程。discard为从自己的children中剔除

怎么冒出,那些危机,怎么解决

 

二 Process类的介绍

创立进程的类

Process([group [, target [, name [, args [, kwargs]]]]]),由该类实例化得到的对象,表示一个子进程中的任务强调:1. 需要使用关键字的方式来指定参数2. args指定的为传给target函数的位置参数,是一个元组形式,必须有逗号

参数介绍:

1 group参数未使用,值始终为None2 3 target表示调用对象,即子进程要执行的任务4 5 args表示调用对象的位置参数元组,args=(1,2,'egon',)6 7 kwargs表示调用对象的字典,kwargs={'name':'egon','age':18}8 9 name为子进程的名称

 方法介绍:

 1 p.start():启动进程,并调用该子进程中的p.run()  2 p.run():进程启动时运行的方法,正是它去调用target指定的函数,我们自定义类的类中一定要实现该方法   3  4 p.terminate():强制终止进程p,不会进行任何清理操作,如果p创建了子进程,该子进程就成了僵尸进程,使用该方法需要特别小心这种情况。如果p还保存了一个锁那么也将不会被释放,进而导致死锁 5 p.is_alive():如果p仍然运行,返回True 6  7 p.join([timeout]):主线程等待p终止(强调:是主线程处于等的状态,而p是处于运行的状态)。timeout是可选的超时时间,需要强调的是,p.join只能join住start开启的进程,而不能join住run开启的进程  

品质介绍:

1 p.daemon:默认值为False,如果设为True,代表p为后台运行的守护进程,当p的父进程终止时,p也随之终止,并且设定为True后,p不能创建自己的新进程,必须在p.start()之前设置2 3 p.name:进程的名称4 5 p.pid:进程的pid6 7 p.exitcode:进程在运行时为None、如果为–N,表示被信号N结束8 9 p.authkey:进程的身份验证键,默认是由os.urandom()随机生成的32字符的字符串。这个键的用途是为涉及网络连接的底层进程间通信提供安全性,这类连接只有在具有相同的身份验证键时才能成功

三 Process类的使用

留意:在windows中Process()必需置于# if __name__ == '__main__':下

澳门电子游戏平台网站全 25澳门电子游戏平台网站全 26

由于Windows没有fork,多处理模块启动一个新的Python进程并导入调用模块。 如果在导入时调用Process(),那么这将启动无限继承的新进程(或直到机器耗尽资源)。 这是隐藏对Process()内部调用的原,使用if __name__ == “__main __”,这个if语句中的语句将不会在导入时被调用。

详见介绍

成立并开启子进度的三种形式

澳门电子游戏平台网站全 27澳门电子游戏平台网站全 28

#开进程的方法一:import timeimport randomfrom multiprocessing import Processdef piao:    print('%s piaoing' %name)    time.sleep(random.randrange(1,5))    print('%s piao end' %name)p1=Process(target=piao,args=('egon',)) #必须加,号p2=Process(target=piao,args=('alex',))p3=Process(target=piao,args=('wupeqi',))p4=Process(target=piao,args=('yuanhao',))p1.start()p2.start()p3.start()p4.start()print('主线程')

方式一澳门电子游戏平台网站全 29澳门电子游戏平台网站全 30

#开进程的方法二:import timeimport randomfrom multiprocessing import Processclass Piao:    def __init__(self,name):        super().__init__()        self.name=name    def run:        print('%s piaoing' %self.name)        time.sleep(random.randrange(1,5))        print('%s piao end' %self.name)p1=Piao('egon')p2=Piao('alex')p3=Piao('wupeiqi')p4=Piao('yuanhao')p1.start() #start会自动调用runp2.start()p3.start()p4.start()print('主线程')

方式二

进度平素的内部存款和储蓄器空间是隔绝的

澳门电子游戏平台网站全 31澳门电子游戏平台网站全 32

from multiprocessing import Processn=100 #在windows系统中应该把全局变量定义在if __name__ == '__main__'之上就可以了def work():    global n    n=0    print('子进程内: ',n)if __name__ == '__main__':    p=Process(target=work)    p.start()    print('主进程内: ',n)

View Code

Process对象的其它形式或性质

澳门电子游戏平台网站全 33澳门电子游戏平台网站全 34

# 进程pid:每一个进程在操作系统内都有一个唯一的id号,称之为pid# 方法一'''from multiprocessing import Process, current_processimport timedef task():    print('%s is running' % current_process    time.sleep    print('%s is done' % current_processif __name__ == '__main__':    p = Process(target=task)    p.start()    print('主进程 ', current_process'''# 方法二# from multiprocessing import Process# import os# import time### def task():#     print('%s is running' % os.getpid#     time.sleep#     print('%s is done' % os.getpid### if __name__ == '__main__':#     p = Process(target=task)#     p.start()#     print('主进程', os.getpidfrom multiprocessing import Processimport osimport timedef task():    print('%s is running 爹是:%s ' % (os.getpid(), os.getppid    time.sleep(2)    print('%s is done 爹是:%s ' % (os.getpid(), os.getppid# os.getpid()获得id号;os.getppid获得父级的id号if __name__ == '__main__':    p = Process(target=task)    p.start()    p.terminate()   #干死进程    print(p.is_alive    #判断是否存活    print('主进程:%s  主进程他爹:%s' % (os.getpid(), os.getppid

View Code