Python 并发编程-进程

Process类参数介绍

group  ——–  参数不用, 值始终为None

target  ——–  表示调用对象, 即子进程而尽之天职

args  ———-  表示调用对象的职位参数元组, args=(1,2,’hades’,)
是一个元组格局,必须有逗号

kwargs  ——-  代表调用对象的字典, kwargs={‘name’:’hades’,’age’:18}

name  ———  为子进程的号

 

Process类方法介绍

p.start()  —————–  启动进程, 并调用该子进程被的p.run()

p.run()  ——————-  进程启动时运行的道,
正是她去调用target指定的函数, 自定义类的接近吃必要贯彻该法

p.terminate()  ———–  强制结束进程p, 不谋面展开此外清理操作,
假设p创造了分支进程, 该子进程就改成了僵尸进程,
使用该形式需要特别小心这种情形.

             假诺p还保存了一个锁那么为将未会晤受放,
进而导致死锁

p.is_alive()  ————–  判断进程是否存活, 假使p如故运行, 重返True

p.join()  ——————- 
主进程等p子进程终止(是主进程处于等之状态,而p子进程处于运行的状态),
只好join住start开启之长河, 不可知join住run开启的过程

 

Process类属性介绍

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字符的字符串.

           
那么些键的用处是为关联网络连接的根进程之中通信提供安全性,这看似连接只有以装有相同之身份验证键时才会不负众望(了解知识点)          

 

 

嗬是过程

应用过程是一旦促成产出效果

 

过程就是一个着开展/运行的次, 换言之, 进程指的是一个主次的运转过程

程序vs进程:

  程序: 只是平等堆代码文件

  进程: 程序运行的历程才是过程

 

串行: 一个职责完完整整地运转了, 再实践下一个任务, 按次序依次举办

判定串行的定义:

  串行看起就是是一个一个运转的: 对

  一个一个底运作就是串行: 错误

 

起(切换+保存状态):  两只任务看起是以运转, 单核就好推行并发

彼此:  五只任务是实在意义上的而运转, 只有多按才会促成互动

 

差不多道技术之发出背景:  就是想使当单核下实现产出

什么贯彻:

  1. 空中上之复用: 将内存分为几局部, 每个有放入一个次的多少,
那样同一时间内存中就出矣多道程序的多寡, 为CPU在差不四个任务之中切换做准备

  2. 时刻达之复用: 多独过程共享CPU的时日

    关键点便是CPU在差不四只任务中展开切换

    有些许种意况下会来切换:

      1. 一个职责占用CPU时间过长(没有赶上IO操作): 会降低功效

      2. 一个任务在运作的长河遭到遭受IO操作: 可以荣升效能

 

开启子进程的办法1

 1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 def task(name):
 6     print('%s is running' % name)
 7     time.sleep(3)
 8     print('%s is done' % name)
 9 
10 
11 # 在windows系统上开启子进程的操作必须放到该行代码下
12 if __name__ == '__main__':
13     p = Process(target=task, args=('子进程',))  # Process(target=task,kwargs={'name':'子进程'}) #
14     p.start()  # 仅仅只是向操作系统发送一个创造子进程的信号
15     print('主')

 终端打印:

图片 1

 

 

开启子进程的主意2

 1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 class Myprocess(Process):
 6     def __init__(self, name):
 7         super().__init__()
 8         self.name = name
 9 
10     def run(self):
11         print('%s is running' % self.name)
12         time.sleep(3)
13         print('%s is done' % self.name)
14 
15 
16 # 在windows系统上开启子进程的操作必须放到该行代码下
17 if __name__ == '__main__':
18     p = Myprocess('子进程')
19     p.start()  # 仅仅只是向操作系统发送一个创造子进程的信号
20     p.join()
21     print('主')

终点打印:

图片 2

 

 join方法

 1 from multiprocessing import Process
 2 import time
 3 
 4 
 5 def task(name, n):
 6     print('%s is running' % name)
 7     time.sleep(n)
 8     print('%s is done' % name)
 9 
10 
11 if __name__ == '__main__':
12     start = time.time()
13     p_l = []
14     for i in range(1, 4):
15         p = Process(target=task, args=('子进程%s' % i, i))
16         p_l.append(p)
17         p.start()
18 
19     for p in p_l:
20         p.join()
21     stop = time.time()
22     print('主', (stop - start))

 终端打印:

图片 3

 

 进程中内存隔离

 1 from multiprocessing import Process
 2 
 3 n = 100
 4 
 5 
 6 def task():
 7     global n
 8     n = 0
 9 
10 
11 if __name__ == '__main__':
12     p = Process(target=task, )
13     p.start()
14     p.join()
15     print('主', n)

 终端打印:

图片 4

 

 进程的PID

 1 from multiprocessing import Process, current_process
 2 import time, os
 3 
 4 
 5 def task():
 6     print('子进程[%s]  父进程<%s>' % (os.getpid(), os.getppid()))
 7     time.sleep(300)
 8 
 9 
10 if __name__ == '__main__':
11     p = Process(target=task)
12     p.start()
13     print('主', os.getpid(), os.getppid())
14     time.sleep(1000)

极限打印:

图片 5

 

 

 进程对象其他相关的属性或方法

 p.name 更改子进程的名字

 1 from multiprocessing import Process
 2 import time, os
 3 
 4 
 5 def task():
 6     print('%s is running' % os.getppid())
 7     time.sleep(300)
 8 
 9 
10 if __name__ == '__main__':
11     p = Process(target=task, name='子进程1')
12     p.start()
13     print(p.name)
14     print('主')
15     time.sleep(1000)

 终端打印:

图片 6

 

terminate与is_alive

  p.terminate()  关闭进程

  p.is_alive()  查看过程是否存活

 1 from multiprocessing import Process
 2 import time, os
 3 
 4 
 5 def task():
 6     print('%s is running' % os.getppid())
 7     time.sleep(300)
 8 
 9 
10 if __name__ == '__main__':
11     p = Process(target=task, name='子进程1')
12     p.start()
13     p.terminate()
14     time.sleep(0.1)
15     print(p.is_alive())
16     print('主')

 终端打印:

图片 7

 

相关文章