欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 房产 > 家装 > 一文速通Python并行计算:08 Python多进程编程-multiprocessing模块、进程的创建命名、获取进程ID、创建守护进程和进程的终止

一文速通Python并行计算:08 Python多进程编程-multiprocessing模块、进程的创建命名、获取进程ID、创建守护进程和进程的终止

2025/5/2 19:55:28 来源:https://blog.csdn.net/weixin_44719294/article/details/147358386  浏览:    关键词:一文速通Python并行计算:08 Python多进程编程-multiprocessing模块、进程的创建命名、获取进程ID、创建守护进程和进程的终止

一文速通 Python 并行计算:08 Python 多进程编程-multiprocessing 模块、进程的创建命名、获取进程 ID、创建守护进程和进程的终止

image

摘要:

本节介绍 Python 中 multiprocessing 模块的基本用法,包括如何创建和命名子进程、获取进程 ID、设置守护进程(daemon)以及安全地终止进程,帮助实现多进程并发编程以提升程序性能。

关于我们更多介绍可以查看云文档:Freak 嵌入式工作室云文档,或者访问我们的 wiki:****https://github.com/leezisheng/Doc/wik

往期推荐:

可能是全网最适合入门的面向对象编程教程:Python实现-嵌入式爱好者必看!

全网最适合入门的面向对象编程教程:00 面向对象设计方法导论

全网最适合入门的面向对象编程教程:01 面向对象编程的基本概念

全网最适合入门的面向对象编程教程:02 类和对象的Python实现-使用Python创建类

全网最适合入门的面向对象编程教程:03 类和对象的Python实现-为自定义类添加属性

全网最适合入门的面向对象编程教程:04 类和对象的 Python 实现-为自定义类添加方法

全网最适合入门的面向对象编程教程:05 类和对象的Python实现-PyCharm代码标签

全网最适合入门的面向对象编程教程:06 类和对象的 Python 实现-自定义类的数据封装

全网最适合入门的面向对象编程教程:07 类和对象的Python实现-类型注解

全网最适合入门的面向对象编程教程:08 类和对象的 Python 实现-@property 装饰器

全网最适合入门的面向对象编程教程:09 类和对象的Python实现-类之间的关系

全网最适合入门的面向对象编程教程:10 类和对象的Python实现-类的继承和里氏替换原则

全网最适合入门的面向对象编程教程:11 类和对象的Python实现-子类调用父类方法

全网最适合入门的面向对象编程教程:12 类和对象的 Python 实现-Python 使用 logging 模块输出程序运行日志

全网最适合入门的面向对象编程教程:13 类和对象的 Python 实现-可视化阅读代码神器 Sourcetrail 的安装使用

全网最适合入门的面向对象编程教程:14 类和对象的Python实现-类的静态方法和类方法

全网最适合入门的面向对象编程教程:15 类和对象的Python实现-__slots__魔法方法

全网最适合入门的面向对象编程教程:16 类和对象的Python实现-多态、方法重写与开闭原则

全网最适合入门的面向对象编程教程:17 类和对象的Python实现-鸭子类型与“file-like object“

全网最适合入门的面向对象编程教程:18 类和对象的Python实现-多重继承与PyQtGraph串口数据绘制曲线图

全网最适合入门的面向对象编程教程:19 类和对象的 Python 实现-使用 PyCharm 自动生成文件注释和函数注释

全网最适合入门的面向对象编程教程:20 类和对象的 Python 实现-组合关系的实现与 CSV 文件保存

全网最适合入门的面向对象编程教程:21 类和对象的 Python 实现-多文件的组织:模块 module 和包 package

全网最适合入门的面向对象编程教程:22 异常捕获-异常和语法错误

全网最适合入门的面向对象编程教程:23 异常捕获-抛出异常

全网最适合入门的面向对象编程教程:24 异常捕获现-异常的捕获与处理:try/except语句、文件读写示例、Exception引用

全网最适合入门的面向对象编程教程:25 异常捕获-Python 判断输入数据类型

全网最适合入门的面向对象编程教程:26 异常捕获-上下文管理器和with语句

全网最适合入门的面向对象编程教程:26 异常捕获-上下文管理器和with语句

全网最适合入门的面向对象编程教程:27 异常捕获-Python 中异常层级与自定义异常类的实现

全网最适合入门的面向对象编程教程:28 异常捕获-Python编程原则、哲学和规范大汇总

全网最适合入门的面向对象编程教程:29 异常捕获-断言与防御性编程和help函数的使用

全网最适合入门的面向对象编程教程:29 异常捕获-断言与防御性编程和help函数的使用

全网最适合入门的面向对象编程教程:30 Python的内置数据类型-object根类

全网最适合入门的面向对象编程教程:31 Python的内置数据类型-对象Object和类型Type

全网最适合入门的面向对象编程教程:32 Python的内置数据类型-类Class和实例Instance

全网最适合入门的面向对象编程教程:33 Python 的内置数据类型-对象 Object 和类型 Type 的关系

全网最适合入门的面向对象编程教程:33 Python 的内置数据类型-对象 Object 和类型 Type 的关系

全网最适合入门的面向对象编程教程:34 Python的内置数据类型-Python常用复合数据类型:元组和命名元组

全网最适合入门的面向对象编程教程:35 Python的内置数据类型-文档字符串和__doc__属性

全网最适合入门的面向对象编程教程:36 Python的内置数据类型-字典

全网最适合入门的面向对象编程教程:37 Python常用复合数据类型-列表和列表推导式

全网最适合入门的面向对象编程教程:38 Python常用复合数据类型-使用列表实现堆栈、队列和双端队列

全网最适合入门的面向对象编程教程:39 Python 常用复合数据类型-集合

全网最适合入门的面向对象编程教程:40 Python 常用复合数据类型-枚举和 enum 模块的使用

全网最适合入门的面向对象编程教程:41 Python常用复合数据类型-队列(FIFO、LIFO、优先级队列、双端队列和环形队列)

全网最适合入门的面向对象编程教程:42 Python常用复合数据类型-collections容器数据类型

全网最适合入门的面向对象编程教程:43 Python常用复合数据类型-扩展内置数据类型

全网最适合入门的面向对象编程教程:44 Python内置函数与魔法方法-重写内置类型的魔法方法

全网最适合入门的面向对象编程教程:45 Python实现常见数据结构-链表、树、哈希表、图和堆

全网最适合入门的面向对象编程教程:46 Python函数方法与接口-函数与事件驱动框架

全网最适合入门的面向对象编程教程:47 Python函数方法与接口-回调函数Callback

全网最适合入门的面向对象编程教程:48 Python函数方法与接口-位置参数、默认参数、可变参数和关键字参数

全网最适合入门的面向对象编程教程:49 Python函数方法与接口-函数与方法的区别和lamda匿名函数

全网最适合入门的面向对象编程教程:50 Python函数方法与接口-接口和抽象基类

全网最适合入门的面向对象编程教程:51 Python函数方法与接口-使用Zope实现接口

全网最适合入门的面向对象编程教程:52 Python函数方法与接口-Protocol协议与接口

全网最适合入门的面向对象编程教程:53 Python字符串与序列化-字符串与字符编码

全网最适合入门的面向对象编程教程:54 Python字符串与序列化-字符串格式化与format方法

全网最适合入门的面向对象编程教程:55 Python字符串与序列化-字节序列类型和可变字节字符串

全网最适合入门的面向对象编程教程:56 Python字符串与序列化-正则表达式和re模块应用

全网最适合入门的面向对象编程教程:57 Python字符串与序列化-序列化与反序列化

全网最适合入门的面向对象编程教程:58 Python字符串与序列化-序列化Web对象的定义与实现

全网最适合入门的面向对象编程教程:59 Python并行与并发-并行与并发和线程与进程

一文速通Python并行计算:00 并行计算的基本概念

一文速通Python并行计算:01 Python多线程编程-基本概念、切换流程、GIL锁机制和生产者与消费者模型

一文速通Python并行计算:02 Python多线程编程-threading模块、线程的创建和查询与守护线程

一文速通Python并行计算:03 Python多线程编程-多线程同步(上)—基于互斥锁、递归锁和信号量

一文速通Python并行计算:04 Python多线程编程-多线程同步(下)—基于条件变量、事件和屏障

一文速通Python并行计算:05 Python多线程编程-线程的定时运行

一文速通 Python 并行计算:06 Python 多线程编程-基于队列进行通信

一文速通Python并行计算:07 Python多线程编程-线程池的使用和多线程的性能评估

更多精彩内容可看:

CM3调试系统简析

肝了半个月,嵌入式技术栈大汇总出炉

Avnet ZUBoard 1CG开发板上手—深度学习新选择

SenseCraft 部署模型到Grove Vision AI V2图像处理模块

比赛获奖的武林秘籍:10 一文速通“大唐杯”全国大学生新一代信息通信技术大赛

比赛获奖的武林秘籍:09 一文速通计算机设计大赛,比赛人必看的获奖秘籍

比赛获奖的武林秘籍:08 一文速通光电设计大赛,电子人必看

比赛获奖的武林秘籍:07 一文速通电子设计大赛,电子人必看的获奖秘籍!

比赛获奖的武林秘籍:06 5 分钟速通比赛路演答辩,国奖选手的血泪经验!

比赛获奖的武林秘籍:05 电子计算机类比赛国奖队伍技术如何分工和学习内容

比赛获奖的武林秘籍:04 电子类比赛嵌入式开发快速必看的上手指南

比赛获奖的武林秘籍:03 好的创意选取-获得国奖的最必要前提

比赛获奖的武林秘籍:02 国奖秘籍-大学生电子计算机类竞赛快速上手的流程,小白必看

比赛获奖的武林秘籍:01 如何看待当代大学生竞赛中“卷”“祖传老项目”“找关系”的现象?

比赛获奖的武林秘籍:00 学科竞赛-工科类大学生绕不开的话题,你了解多少?

开源一款I2C电机驱动扩展板-FreakStudio多米诺系列

开源一款数据转换扩展板-FreakStudio多米诺系列

开源一款串口舵机驱动扩展板-FreakStudio多米诺系列

开源一款DDS信号发生扩展板-FreakStudio多米诺系列

手把手教你用 MicroPython 玩转幻尔串口舵机,代码+教程全公开

万字长文手把手教你实现MicroPython/Python发布第三方库

三分钟教学:手把手教你实现Arduino发布第三方库

【电子DIY神器】通吃各种5线步进电机!I2C接口控制28BYJ-48五线四相步进电机

文档获取:

可访问如下链接进行对文档下载:

https://github.com/leezisheng/Doc

该文档是一份关于 并行计算Python 并发编程 的学习指南,内容涵盖了并行计算的基本概念、Python 多线程编程、多进程编程以及协程编程的核心知识点:

image

正文

Python 中的多线程无法利用多核优势,如果想要充分地使用多核 CPU 的资源,在 python 中大部分情况需要使用多进程。Python 提供了 multiprocessing 模块用来开启子进程,并在子进程中执行我们定制的任务(比如函数),该模块与多线程模块 threading 的编程接口类似。multiprocessing 模块的功能众多:支持子进程、通信和共享数据、执行不同形式的同步,提供了 ProcessQueuePipeLock 等组件。

1.进程的创建

首先我们看一下 multiprocessing.Process 对象:

class multiprocessing.Process(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)

其中:

group :应该始终是 None ;它仅用于兼容 threading.Thread 。 
target :是由 run() 方法调用的可调用对象。它默认为 None ,意味着什么都没有被调用。 
name :是进程名称(有关详细信息,请参阅 name )。 
args :是目标调用的参数元组。 args 参数默认值为 (),可被用来指定要传递给 target 的参数列表或元组。
Kwargs:是目标调用的关键字参数字典。
daemon:将进程 daemon 标志设置为 True 或 False 。如果是 None (默认值),则该标志将从创建的进程继承。

1.1 调用 Process 类的构造器创建进程

Process 类提供了 __init__() 构造器,可以用来创建进程,其常见启动进程的方法包括:

image

进程的属性包括:

image

这里,我们进行进程创建和启动的测试,代码如下:

from multiprocessing import  Processdef fun1(name):print('测试%s多进程' %name)if __name__ == '__main__':process_list = []for i in range(5):  _#开启5个子进程执行fun1函数_p = Process(target=fun1,args=('Python',)) _#实例化进程对象_p.start()process_list.append(p)for i in process_list:p.join()print('结束测试')

上面的代码开启了 5 个子进程去执行函数,我们可以观察结果,是同时打印的,这里实现了真正的并行操作,就是多个 CPU 同时执行任务。

image

我们知道进程是 python 中最小的资源分配单元,也就是进程中间的数据,内存是不共享的,每启动一个进程,都要独立分配资源和拷贝访问的数据,所以进程的启动和销毁的代价是比较大了。注意,使用进程对象调用 join() 方法。如果没有 join() ,主进程退出之后子进程会留在idle中,你必须手动杀死它们。

1.2 继承 Process 类创建进程类

如果子类重写构造函数,它必须确保它在对进程执行任何其他操作之前调用基类构造函数 Process.__init__() ,同时,对于 run() 方法,可以查看官方文档:

image

这里,测试代码如下:

from multiprocessing import  Processclass MyProcess(Process): _#继承Process类_def __init__(self,name):super(MyProcess,self).__init__()self.name = namedef run(self):print('测试%s多进程' % self.name)if __name__ == '__main__':process_list = []for i in range(5):  _#开启5个子进程执行fun1函数_p = MyProcess('Python') _#实例化进程对象_p.start()process_list.append(p)for i in process_list:p.join()print('结束测试')

结果如下,效果和第一种方式一样:

image

**注意:在 windows 中****Process()必须放到if name == ‘main’😗*

image

通过在 main 代码块中实例化进程对象,我们可以预防无限递归调用。最佳实践是在不同的脚本文件中定义目标函数,然后导入进来使用。

image

2.进程的命名

在上一节的例子中,我们创建了一个进程,并为其分配了目标函数和函数变量。然而如果能给进程分配一个名字,那么 debug 的时候就更方便了。

current_process() 可以返回返回与当前进程相对应的 Process 对象。下面的代码在主程序中创建了一个有名字的进程和一个没有名字的进程,目标函数都是 foo() 函数。

import multiprocessing
import timedef foo():name = multiprocessing.current_process().nameprint("Starting %s \n" % name)time.sleep(3)print("Exiting %s \n" % name)if __name__ == '__main__':process_with_name = multiprocessing.Process(name='foo_process', target=foo)process_with_default_name = multiprocessing.Process(target=foo)process_with_name.start()process_with_default_name.start()

如下为运行结果:

image

3.获取进程的 PID

进程控制符(PID),英文全称为 Process Identifier。也常被称为进程标识符。顾名思义,它是各进程的身份标识,程序一运行系统就会自动分配给进程一个独一无二的 PID。进程中止后 PID 被系统回收,可能会被继续分配给新运行的程序。

这里可以使用 current_process().pid 获取当前进程的 PID。将如上代码中 current_process().name 改为 current_process().pid,可得:

image

4.守护进程

守护进程是一种进程驻留内存的后台进程,它脱离终端控制,不受终端信号影响,即 Ctrl+C,通常守护进程用于周期性的执行某种任务或持续等待处理某些发生的事件。当主进程终止时,守护进程随机终止(本质上是在主进程结束之前结束的,主进程需要负责回收资源)。

如果需要处理比较巨大的任务,又不需要人为干预,将其作为后台进程执行是个非常常用的编程模型。此进程又可以和其他进程并发执行。通过 Python 的 multiprocessing 模块的后台进程选项,我们可以让进程在后台运行。

为了在后台运行进程,我们设置 daemon 参数为 True

image

代码如下:

import multiprocessing
import timedef foo():name = multiprocessing.current_process().nameprint("Starting %s " % name)time.sleep(3)print("Exiting %s " % name)if __name__ == '__main__':background_process = multiprocessing.Process(name='background_process', target=foo)background_process.daemon = TrueNO_background_process = multiprocessing.Process(name='NO_background_process', target=foo)NO_background_process.daemon = Falsebackground_process.start()NO_background_process.start()

运行结果如下:

image

在非后台运行的进程会看到一个输出,后台运行的没有输出,后台运行进程在主进程结束之后会自动结束。

5.进程的终止

我们可以使用 terminate() 方法立即杀死一个进程。另外,我们可以使用 is_alive() 方法来判断一个进程是否还存活:

image

image

在本例中,创建一个目标函数为 foo() 的进程。启动之后,我们通过 terminate() 方法杀死它。

import multiprocessing
import timedef foo():print('Starting function')time.sleep(0.1)print('Finished function')if __name__ == '__main__':p = multiprocessing.Process(target=foo)print('Process before execution:', p, p.is_alive())p.start()print('Process running:', p, p.is_alive())p.terminate()print('Process terminated:', p, p.is_alive())p.join()print('Process joined:', p, p.is_alive())print('Process exit code:', p.exitcode)

运行结果如下:

image

我们创建了一个线程,然后用 is_alive() 方法监控它的生命周期。然后通过调用 terminate() 方法结束进程。最后,我们通过读进程的 ExitCode 状态码(status code)验证进程已经结束。

image

image

image

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

热搜词