多进程编程与进程间通信及数据传输Python代码实现

• 值范围：-20 -- 19 -20为最高优先级❓♶使用正在运行的程序❓♺ 不错：设置运行优先级，例如:好-9./while.py --->>以优先级-9运行

进程特性

1. 进程之间互不影响，独立工作
2. 进程是最小的操作系统资源单元每个进程都有独立的空间，各自占用一定的虚拟内存

孤儿进程

1. 父进程先于子进程退出。目前，子进程称为孤儿进程
2. 孤儿进程是操作系统指定的进程 接受后，系统进程成为孤儿进程的主进程

僵尸进程

1. 进程在父进程退出前退出，但父进程不处理子进程的退出状态。这时子进程就变成了僵尸进程
2. 僵尸进程在内存中保留了少量的PCB信息。大量僵尸进程消耗系统资源。应避免生成僵尸进程

• 如何避免生成僵尸进程
  • 处理子进程退出状态

    pid, status = os.wait()

  • 功能：子进程退出及等待时间

    返回值：

需要理解

1. 什么是流程？ ？
2. 子进程从下一个fork语句开始执行，不干扰父进程
3. 父子进程的执行顺序可能不固定。父子进程共享一个终端屏幕
4. 父子进程通常会根据fork返回值的差异来选择执行不同的进程。 if代码的结构几乎是fork的标准
5. 父子进程空间是独立的，操作都是这个空间的内容，互不影响
6. 子进程也有自己的属性，比如PID号、PCB、指令集等

进程相关函数

功能方法	参数	进程说明
当前进程的编号 Pren。
os.getppid()		返回进程父进程当前 PID 号
os._exit( status )	程序退出状态	进程退出
它）❙] Number：显示退出状态，不写 默认为	进程退出

import os
pid = os.fork()
if pid < 0:
    print("创建进程失败")
elif pid == 0:
    print("子进程我的真实PID为：",os.getpid(),"我的父进程PID为：",os.getppid())
else:
    print("我是父进程执行的代码,当前的变量pid为：",pid,"我的真实PID为：",os.getpid())
    
'''打印内容''''''
我是父进程执行的代码,当前的变量pid为： 10992 我的真实PID为： 10991
子进程我的真实PID为： 10992 我的父进程PID为： 10991
''''''打印内容'''
    
# 如果pid 10992和子进程真实PID不同，那么这个子进程就变成了孤儿进程

from multiprocessing import Process

Process () 根据位置

7. kwargs 的函数目标函数：字典，成对传递参数给目标函数键值
8. 名称：字符串，新进程名称
9. 例如： p = Process(target = fun,args=(a,b))

函数方法	说明
p.start()	启动进程，目标函数自动执行，此时进程真正创建完成 on([p.	等待子进程回收的块，超时为过期时间
p.is_alive()	设置进程的生命周期状态，这个是生命周期中的，返回一个布尔值 p.name()	获取进程名称
p.pid()	获取进程pid
p.daemon() 默认状态为False。退出父进程不会影响子进程。正确：子进程随主进程结束

• 使用多处理创建子进程。同样，子进程复制父进程的所有代码。父子进程独立执行，互不影响。父子进程有自己的工作空间
• 如果不使用 join 引用子进程的话，子进程退出后就会变成僵尸进程

from multiprocessing import Process 
from time import sleep 
​
#带参数的进程函数
def worker(sec,name):
    for i in range(3):
        sleep(sec)
        print("I'm %s"%name)
        print("I'm working...")
​
p = Process(target = worker,args = (2,),\
    kwargs = {'name':'Daivl'},name = "Worker")
p.start()
​
print("Process name:",p.name) #进程名称
print("Process PID:",p.pid) #获取进程PID
​
#进程alive情况
print("Process is alive:",p.is_alive())
​
p.join(3)
print("==================")

1. 继承进程
2. 自己写__init__，同时加载这个_init方法
3. 并覆盖 Start 方法，可自动运行通过在创建的对象上调用 start

from  import Process
import time
​
class ClockProcess(Process):
​
    def __init__(self,value):
        self.value = value
        super(ClockProcess,self).__init__()
​
    def run(self):
        for i in range(5):
            print("现在的时间是",time.ctime())
            time.sleep(self.value)
​
# 创建自定义进的类的对象
p =ClockProcess(2)
​
# 自动调用run
p.start()
p.join()    

原因是需要完成几个过程❝ 。进程需要频繁的创建和删除，给计算机带来较多的资源消耗

Pool function

• Pool(Processes)
  • 功能：创建多个进程池对象 † ive func as tuple 传递参数
  • kwds ：将参数传递给函数 func in字典的形式
• 返回对象值

from multiprocessing import Process
import time
​
class ClockProcess(Process):
​
    def __init__(self,value):
        self.value = value
        super(ClockProcess,self).__init__()
​
    def run(self):
        for i in range(5):
            print("现在的时间是",time.ctime())
            time.sleep(self.value)
​
# 创建自定义进的类的对象
p =ClockProcess(2)
​
# 自动调用run
p.start()
p.join()