前面介绍了使用 os.fork() 函数实现多进程编程,该方法最明显的缺陷就是不适用于 Windows 系统。本节将介绍一种支持 Python 在 Windows 平台上创建新进程的方法。
Python multiprocessing 模块提供了 Process 类,该类可用来在 Windows 平台上创建新进程。和使用 Thread 类创建多线程方法类似,使用 Process 类创建多进程也有以下 2 种方式:
直接创建 Process 类的实例对象,由此就可以创建一个新的进程;
通过继承 Process 类的子类,创建实例对象,也可以创建新的进程。注意,继承 Process 类的子类需重写父类的 run() 方法。
不仅如此,Process 类中也提供了一些常用的属性和方法,如表 1 所示。
表 1 Python Process类常用属性和方法
接下来将一一对创建进程的 2 种方法做详细的讲解。
通过Process类创建进程
和使用 thread 类创建子线程的方式非常类似,使用 Process 类创建实例化对象,其本质是调用该类的构造方法创建新进程。Process 类的构造方法格式如下:
def __init__(self,group=None,target=None,name=None,args=(),kwargs={})
其中,各个参数的含义为:
- group:该参数未进行实现,不需要传参;
- target:为新建进程指定执行任务,也就是指定一个函数;
- name:为新建进程设置名称;
- args:为 target 参数指定的参数传递非关键字参数;
- kwargs:为 target 参数指定的参数传递关键字参数。
下面程序演示了如何用 Process 类创建新进程。
from multiprocessing import Process import os print("当前进程ID:",os.getpid()) # 定义一个函数,准备作为新进程的 target 参数 def action(name,*add): print(name) for arc in add: print("%s --当前进程%d" % (arc,os.getpid())) if __name__=='__main__': #定义为进程方法传入的参数 my_tuple = ("http://jb51.net/python/", "http://jb51.net/shell/", "http://jb51.net/java/") #创建子进程,执行 action() 函数 my_process = Process(target = action, args = ("my_process进程",*my_tuple)) #启动子进程 my_process.start() #主进程执行该函数 action("主进程",*my_tuple)
程序执行结果为:
当前进程ID: 12980
主进程
http://jb51.net/python/ --当前进程12980
http://jb51.net/shell/ --当前进程12980
http://jb51.net/java/ --当前进程12980
当前进程ID: 12860
my_process进程
http://jb51.net/python/ --当前进程12860
http://jb51.net/shell/ --当前进程12860
http://jb51.net/java/ --当前进程12860
需要说明的是,通过 multiprocessing.Process 来创建并启动进程时,程序必须先判断 if __name__=='__main__':,否则运行该程序会引发异常。
此程序中有 2 个进程,分别为主进程和我们创建的新进程,主进程会执行整个程序,而子进程不会执行 if __name__ == '__main__' 中包含的程序,而是先执行此判断语句之外的所有可执行程序,然后再执行我们分配让它的任务(也就是通过 target 参数指定的函数)。
通过Process继承类创建进程
和使用 thread 子类创建线程的方式类似,除了直接使用 Process 类创建进程,还可以通过创建 Process 的子类来创建进程。
需要注意的是,在创建 Process 的子类时,需在子类内容重写 run() 方法。实际上,该方法所起到的作用,就如同第一种创建方式中 target 参数执行的函数。
另外,通过 Process 子类创建进程,和使用 Process 类一样,先创建该类的实例对象,然后调用 start() 方法启动该进程。下面程序演示如何通过 Process 子类创建一个进程。
from multiprocessing import Process import os print("当前进程ID:",os.getpid()) # 定义一个函数,供主进程调用 def action(name,*add): print(name) for arc in add: print("%s --当前进程%d" % (arc,os.getpid())) #自定义一个进程类 class My_Process(Process): def __init__(self,name,*add): super().__init__() self.name = name self.add = add def run(self): print(self.name) for arc in self.add: print("%s --当前进程%d" % (arc,os.getpid())) if __name__=='__main__': #定义为进程方法传入的参数 my_tuple = ("http://jb51.net/python/", "http://jb51.net/shell/", "http://jb51.net/java/") my_process = My_Process("my_process进程",*my_tuple) #启动子进程 my_process.start() #主进程执行该函数 action("主进程",*my_tuple)
程序执行结果为:
当前进程ID: 22240
主进程
http://jb51.net/python/ --当前进程22240
http://jb51.net/shell/ --当前进程22240
http://jb51.net/java/ --当前进程22240
当前进程ID: 18848
my_process进程
http://jb51.net/python/ --当前进程18848
http://jb51.net/shell/ --当前进程18848
http://jb51.net/java/ --当前进程18848
显然,该程序的运行结果与上一个程序的运行结果大致相同,它们只是创建进程的方式略有不同而已。
推荐读者使用第一种方式来创建进程,因为这种方式不仅编程简单,而且进程直接包装 target 函数,具有更清晰的逻辑结构。
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
更新日志
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]