python并发编程之多进程（实现）

1 from multiprocessing import Process         #导入模块
2 
3 def func(x):                                #定义一个函数（等待开一个新线程执行的函数）
4     print(x)
5 
6 if __name__ == '__main__':                  #windows下一定要加上这句话才能运行
7     p = Process(target=func,args=('传参',)) #实例化一个进程，将函数名作为参数传递，将需要传给函数的参数（元组形式）传递
8     p.start()                               #（通知操作系统）开启此进程

from multiprocessing import Process     #调用模块

class MyProcess(Process):               #定义一个类，必须要继承Process类
    def __init__(self,name):            #如果需要参数，一定要有init方法
        super().__init__()              #如果有init方法，一定要调用父类的init方法
        self.name = name

    def run(self):                      #一定要实现一个run方法来重写父类的run
        print('子进程%s已开启'%self.name)

if __name__ == '__main__':
    p = MyProcess('aaa')                #实例化一个自定义类的对象
    p.start()                           #开启进行

target表示调用对象，既子进程要执行的任务
args表示调用对象的位置参数元组，如：args=(1,)或者args=(1,2)
kwargs表示调用对象的字典，如：kwargs={'name':'fuyong'}

p.start()    启动进程，并且调用该子进程的run()方法
p.run()      进程启动时运行的方法，正式它去调用target指定的函数，我们自定义类的话一定要实现该方法
P.terminate()强制终止程序p，不会进行任何清理操作，如果p创建了子进程，那么该子进程就成了‘僵尸进程
             使用此方法时要特别小心，如果p还保留了一个锁，那么锁也不会被释放，进而导致了死锁
p.is_alive() 判断p是否还在运行，在运行返回True
p.join()     如果加上此方法，那么主线程将等着此线程运行完毕之后才会运行

p.daemon 默认值为False，如果设置为True，则代表后台运行的守护进程，当p的父进程终止时，p也会随之终止

p.name 进程名

p.pid 进程的pid

主进程创建守护进程

　　其一：守护进程会在主进程代码执行结束后就终止

　　其二：守护进程内无法再开启子进程,否则抛出异常：AssertionError: daemonic processes are not allowed to have children

注意：进程之间是互相独立的，主进程代码运行结束，守护进程随即终止



设置守护进程的方法：

p.daemon = True
p.daemon 默认值为False，如果设置为True，则代表后台运行的守护进程，当p的父进程终止时，p也会随之终止

from multiprocessing import Queue

q = Queue(3)  #限制最多放3个  如果超过3个则会堵塞，需要等待拿出去1个之后才能继续放

q.put(1)      #放数据（可以放任何数据类型）
q.put(2)      #放数据（可以放任何数据类型）
q.put(3)      #放数据（可以放任何数据类型）

print(q.get()) #拿数据
print(q.get()) #拿数据
print(q.get()) #拿数据