Python进程multiprocessing.Process()的使用解读

 更新时间:2024年02月24日 09:32:40   作者:埃菲尔没有塔尖  
这篇文章主要介绍了Python进程multiprocessing.Process()的使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

1.进程概念

进程是资源分配的最小单位,程序隔离的边界。


CPU的时间片轮转,在不同的时间段切换执行不同的进程,但是切换进程是比较耗时的;就引来了轻量级进程,也就是所谓的线程,一个进程中包括多个线程(代码流,其实也就是进程中同时跑的多个方法体)

  • 程序:例如xxx.py这是程序,是一个静态的
  • 进程:一个程序运行起来后,代码+用到的资源 称之为进程,它是操作系统分配资源的基本单元。

2.进程的状态

工作中,任务数往往大于cpu的核数,即一定有一些任务正在执行,而另外一些任务在等待cpu进行执行,因此导致了有了不同的状态


  • 就绪态:运行的条件都已经满足,正在等在cpu执行
  • 执行态:cpu正在执行其功能
  • 等待态:等待某些条件满足,例如一个程序sleep了,此时就处于等待态

3.进程的创建-multiprocessing

multiprocessing模块就是跨平台版本的多进程模块,提供了一个Process类来代表一个进程对象,这个对象可以理解为是一个独立的进程,可以执行另外的事情。

方法说明:

创建子进程跟创建线程十分类似,只需要传入一个执行函数和函数的参数,创建一个Process实例,用start()方法启动。

Process语法结构如下: Process([group [, target [, name [, args [, kwargs]]]]])

  • target:如果传递了函数的引用,这个子进程就执行这里(函数)的代码
  • args:给target指定的函数传递的参数,以元组的方式传递
  • kwargs:给target指定的函数传递命名参数
  • name:给进程设定一个名字,可以不设定 group:指定进程组,大多数情况下用不到

Process创建的实例对象的常用方法:

  • start():启动子进程实例(创建子进程)
  • is_alive():判断进程子进程是否还在活着
  • join([timeout]):是否等待子进程执行结束,或等待多少秒
  • terminate():不管任务是否完成,立即终止子进程

Process创建的实例对象的常用属性:

  • name:当前进程的别名,默认为Process-N,N为从1开始递增的整数
  • pid:当前进程的pid(进程号)

代码示例:

import multiprocessing
import time

def work1():
    for i in range(10):
        print("work1----", i)
        time.sleep(0.5)

if __name__ == '__main__':
    # 创建进程
    # 1. 导入 multiprocessing 模块
    # 2. multiprocessing.Process() 创建子进程
    # 3. start() 方法启动进程

    p1 = multiprocessing.Process(group=None, target=work1)
    p1.start()

    for i in range(10):
        print("这是主进程", i)
        time.sleep(0.5)

4.进程名称获取

multiprocessing.current_process()


5. 获取进程pid

有两种方法可以获取

1)multiprocessing.current_process().pid

2)使用import os模块的getpid()

import multiprocessing
import time
import os

def work():
    # 获取进程的名称
    print(multiprocessing.current_process())
    # 获取进程的pid
    print(multiprocessing.current_process().pid, os.getpid())

    i = 0
    while i < 10:
        print("work中执行", i)
        time.sleep(0.5)
        i = i + 1

if __name__ == '__main__':
    # 获取进程的pid
    print(multiprocessing.current_process())
    # 创建子进程
    process1 = multiprocessing.Process(group=None, target=work)
    process1.start()

    i = 0
    while i < 10:
        print("我在主线程中执行",i)
        time.sleep(0.3)
        i = i + 1


 

获取父id: getppid() 获取父进程id

6.子进程参数传递

给子进程传递参数方法和给子线程传递参数方法基本一致!


7.进程间不共享全局变量

import multiprocessing
# 定义全局变量
num = 100

# 定义work方法,设置num1的值
def work():
    global num       # 在函数内部声明使用全局变量num
    num = num + 1    # 对num值进行+1
    print("work num = %d" % num)

# 定义work2方法,获取num1的值
def work2():
    print("work2 num = %d" % num)

if __name__ == '__main__':
    # 创建子进程
    process1 = multiprocessing.Process(group=None, target=work, name="MyProcess")
    process1.start()

    # 创建第二个子进程
    process2 = multiprocessing.Process(group=None, target=work2, name="MyProcess2")
    process2.start()

运行结果:

work num = 101
work2 num = 100

由运行结果可以看出,work函数对num1的修改,在work2中并没有获取到,而还是原来的100,所以,进程之间是不能够共享变量的

8.守护主进程

import multiprocessing
import time

def sub_process():
    for i in range(10):
        print("子进程运行中", i)
        time.sleep(0.5)

if __name__ == '__main__':
    # 创建子进程
    p1 = multiprocessing.Process(group=None, target=sub_process, name="p1")
    # 设置守护主进程
    # 第一种方式:
    # p1.daemon = True
    # 第二种方式(最好在退出exit()前一句使用):
    # p1.terminate()
    # 启动
    p1.start()

    time.sleep(2)
    print("OVER!")
    p1.terminate()
    exit()

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Python 实现顺序高斯消元法示例

    Python 实现顺序高斯消元法示例

    今天小编就为大家分享一篇Python 实现顺序高斯消元法示例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-12-12
  • 教你如何用pycharm安装pyqt5及其相关配置

    教你如何用pycharm安装pyqt5及其相关配置

    这篇文章主要介绍了教你如何用pycharm安装pyqt5及其相关配置,首先通过单独创建一个文件夹来专门存放pyqt5的代码并建立虚拟环境展开文章叙述,需要的小伙伴可以参考一下
    2022-04-04
  • python实现盲盒抽奖功能(减库存)

    python实现盲盒抽奖功能(减库存)

    本文主要介绍了python实现盲盒抽奖功能,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-09-09
  • Python实战基础之Pandas统计某个数据列的空值个数

    Python实战基础之Pandas统计某个数据列的空值个数

    我们在处理数据的时候,经常需要检查数据的质量,也需要知道出问题的数据在哪个位置,下面这篇文章主要给大家介绍了关于Python实战基础之利用Pandas统计某个数据列空值个数的相关资料,需要的朋友可以参考下
    2022-08-08
  • Python图像运算之图像点运算与灰度化处理详解

    Python图像运算之图像点运算与灰度化处理详解

    这篇文章主要介绍了图像点运算的灰度化处理的相关知识,包括各种灰度算法的实现,以及灰度线性变换和灰度非线性变换。需要的可以参考一下
    2022-02-02
  • 基于Django框架的权限组件rbac实例讲解

    基于Django框架的权限组件rbac实例讲解

    今天小编就为大家分享一篇基于Django框架的权限组件rbac实例讲解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-08-08
  • Django mysqlclient安装和使用详解

    Django mysqlclient安装和使用详解

    这篇文章主要介绍了Django mysqlclient安装和使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-09-09
  • 全面解析Python的While循环语句的使用方法

    全面解析Python的While循环语句的使用方法

    这篇文章主要介绍了全面解析Python的While循环语句的使用方法,是Python入门学习中的基础知识,需要的朋友可以参考下
    2015-10-10
  • 基于Python的A*算法解决八数码问题实现步骤

    基于Python的A*算法解决八数码问题实现步骤

    这篇文章主要给大家介绍了关于如何基于Python的A*算法解决八数码问题的实现步骤,文中介绍了八数码问题及其求解方法,通过启发式搜索算法,特别是A*算法,可以有效地解决八数码问题,,需要的朋友可以参考下
    2024-11-11
  • PyQt信号和槽机制的具体使用

    PyQt信号和槽机制的具体使用

    信号和槽机制是一种通信机制,在PyQt中,信号是一种特殊的函数,它可以传递任何类型的数据,而槽则是一种接收信号的函数,本文就介绍了PyQt信号和槽机制的具体使用,感兴趣的可以了解一下
    2023-08-08

最新评论