python中的多进程的创建与启动方式

 更新时间:2022年12月01日 16:49:31   作者:小树苗m  
这篇文章主要介绍了python中的多进程的创建与启动,python中的并发有三种形式,多进程、多线程、协程,执⾏并发任务的⽬的是为了提⾼程序运⾏的效率,本文通过实例代码详细讲解需要的朋友可以参考下

python中的并发有三种形式,多进程、多线程、协程。执⾏并发任务的⽬的是为了提⾼程序运⾏的效率。

一、多进程的创建:多进程的创建方法有两种:

1、通过Process创建多进程 Process语法结构:

			Process(group, target, name, args, kwargs)
			group:指定进程组,⼤多数情况下⽤不到
			target:表示调用对象,即子进程要执行的任务
			name:子进程的名称,可以不设定
			args:给target指定的函数传递的参数,以元组的⽅式传递
			kwargs:给target指定的函数传递命名参数

Process常用方法:

			p.start() 启动进程,并调用该子进程中的p.run()方法
			p.join(timeout):主进程等待⼦进程执⾏结束再结束,timeout是可选的超时时间
			is_alive():判断进程⼦进程是否还存活
			p.run() 进程启动时运行的方法,正是它去调用target指定的函数
			p.terminate() ⽴即终⽌⼦进程

(1)首先,定义一个待调用的函数:

import os
from multiprocessing import Process
def add(name,num):
    nums = 0
    for i in range(num+1):
        nums = nums+i
    print("用户%s:\n  相加结果为:%s \n  当前进程id为:%s \n  当前子进程的父进程id: %s"%(name,nums,os.getpid(),os.getppid()))

(2)创建并启动一个进程

def test1():
    '''启动一个进程调用'''
    name= '王五'
    p = Process(target=add,args=(name,10,))
    p.start()
    p.join()

其中,p.join()方法可以让主进程等待子进程结束之后再结束,如果不加这个方法,主进程结束,子进程还没有结束。
(2)创建并启动多个进程

def test3():
    names = ['王五','赵六','王麻子']
    process_list=[]
    for name in names:
        p = Process(target=add,args=(name,10,))
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()

2、通过进程池创建并启动多进程

进程池可以提供指定数量的进程给用户使用,即当有新的请求提交到进程池中时,如果池未满,则会创建一个新的进程用来执行该请求;反之,如果池中的进程数已经达到规定最大值,那么该请求就会等待,只要池中有进程空闲下来,该请求就能得到执行。
Pool(numprocess, initializer, initargs)
numprocess 是要创建的进程数。如果省略此参数,默认为cpu的最大核心数。
Initializer是每个工作进程启动时要执行的可调用对象。
Initargs 传递给 initializer 的参数元祖,默认为 None

def test4():
    from multiprocessing import Pool
    '''启动多个进程2:进程池'''
    p = Pool(5)
    names = ['王五','赵六','王麻子']
    for name in names:
        p.apply_async(add,args=(name,10))
    p.close()
    p.join()

3、通过继承的方法创建多进程

(1)首先创建一个进程

class SubProcess(Process):
    def __init__(self,name,number):
        super(SubProcess, self).__init__()
        self.name = name
        self.number = number
    def run(self):
        sums = 0
        for i in range(self.number):
            sums = sums+i
        print("用户%s:\n  相加结果为:%s \n  当前进程id为:%s \n  当前子进程的父进程id: %s"\
              %(self.name,self.number,os.getpid(),os.getppid()))

(2)启动一个进程

def call_Sub0():
    '''启动一个进程调用'''
    name = '张三'
    p = SubProcess(name,10)
    p.start()
    p.join()

(3)通过列表启动多个进程

def call_Sub1():
    '''启动多个进程1'''
    names = ['王五','赵六','王麻子']
    process_list=[]
    for name in names:
        p = SubProcess(name,10)
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()
 if __name__ == '__main__':
    print("当前主进程id:",os.getpid())
    call_Sub1()
    print("计算结束!")

4、进程创建与启动完整代码

import os
from multiprocessing import Process
def add(name,num):
    nums = 0
    for i in range(num+1):
        nums = nums+i
    print("用户%s:\n  相加结果为:%s \n  当前进程id为:%s \n  当前子进程的父进程id: %s"%(name,nums,os.getpid(),os.getppid()))
def test1():
    '''启动一个进程调用'''
    name= '王五'
    p = Process(target=add,args=(name,10,))
    p.start()
    p.join()
def test3():
    '''启动多个进程2'''
    names = ['王五','赵六','王麻子']
    process_list=[]
    for name in names:
        p = Process(target=add,args=(name,10,))
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()
'''
进程池:可以提供指定数量的进程给用户使用,即当有新的请求提交到进程池中时,
如果池未满,则会创建一个新的进程用来执行该请求;反之,如果池中的进程数已经达到规定最大值,
那么该请求就会等待,只要池中有进程空闲下来,该请求就能得到执行。
'''
def test4():
    from multiprocessing import Pool
    '''启动多个进程2:进程池'''
    p = Pool(5)
    names = ['王五','赵六','王麻子']
    for name in names:
        p.apply_async(add,args=(name,10))
    p.close()
    p.join()

class SubProcess(Process):
    def __init__(self,name,number):
        super(SubProcess, self).__init__()
        self.name = name
        self.number = number
    def run(self):
        sums = 0
        for i in range(self.number):
            sums = sums+i
        print("用户%s:\n  相加结果为:%s \n  当前进程id为:%s \n  当前子进程的父进程id: %s"\
              %(self.name,self.number,os.getpid(),os.getppid()))
def call_Sub0():
    '''启动一个进程调用'''
    name = '张三'
    p = SubProcess(name,10)
    p.start()
    p.join()
def call_Sub1():
    '''启动多个进程1'''
    names = ['王五','赵六','王麻子']
    process_list=[]
    for name in names:
        p = SubProcess(name,10)
        p.start()
        process_list.append(p)
    for j in process_list:
        j.join()

if __name__ == '__main__':
    print("当前主进程id:",os.getpid())
    call_Sub1()
    print("计算结束!")

到此这篇关于python中的多进程的创建与启动的文章就介绍到这了,更多相关python多进程创建与启动内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • python自动安装pip

    python自动安装pip

    这篇文章主要介绍了python自动安装pip的示例,需要的朋友可以参考下
    2014-04-04
  • Python列表list操作符实例分析【标准类型操作符、切片、连接字符、列表解析、重复操作等】

    Python列表list操作符实例分析【标准类型操作符、切片、连接字符、列表解析、重复操作等】

    这篇文章主要介绍了Python列表list操作符,结合实例形式分析了标准类型操作符、切片、连接字符、列表解析、重复操作等使用技巧,需要的朋友可以参考下
    2017-07-07
  • python pywinauto使用过程及问题小结

    python pywinauto使用过程及问题小结

    在pywinauto库中,uia即UIAutomation,是微软提供的用于用户界面自动化测试和辅助功能访问的技术框架,UIAutomation支持自动化脚本与各种UI元素交互,本文给大家介绍python pywinauto使用过程及问题小结,感兴趣的朋友一起看看吧
    2024-10-10
  • 在python中对于bool布尔值的取反操作

    在python中对于bool布尔值的取反操作

    这篇文章主要介绍了在python中对于bool布尔值的取反操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • 详解如何用django实现redirect的几种方法总结

    详解如何用django实现redirect的几种方法总结

    这篇文章主要介绍了如何用django实现redirect的几种方法总结,详细的介绍3种实现方式,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2018-11-11
  • Python区块链客户端类开发教程

    Python区块链客户端类开发教程

    这篇文章主要为大家介绍了Python区块链客户端类开发教程,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-05-05
  • python 瀑布线指标编写实例

    python 瀑布线指标编写实例

    这篇文章主要介绍了python 瀑布线指标编写实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-06-06
  • python遍历字符串中每一个字符的4种方式

    python遍历字符串中每一个字符的4种方式

    很多计算过程都需要每次从一个字符串中取一个字符,下面这篇文章主要给大家介绍了关于python遍历字符串中每一个字符的4种方式,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2023-05-05
  • Python读取Excel数据实现批量生成PPT

    Python读取Excel数据实现批量生成PPT

    我们常常面临着大量的重复性工作,通过人工方式处理往往耗时耗力易出错。而Python在办公自动化方面具有天然优势。本文将利用读取Excel数据并实现批量生成PPT,需要的可以参考一下
    2022-05-05
  • Anaconda配置各版本Pytorch的实现

    Anaconda配置各版本Pytorch的实现

    本文是整理目前全版本pytorch深度学习环境配置指令,以下指令适用Windows操作系统,在Anaconda Prompt中运行,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-08-08

最新评论