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多进程创建与启动内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 在Django中使用Sitemap的方法讲解

    在Django中使用Sitemap的方法讲解

    这篇文章主要介绍了在Django中使用Sitemap的方法讲解,Django是最具人气的Python web开发框架,需要的朋友可以参考下
    2015-07-07
  • 详解python中自定义超时异常的几种方法

    详解python中自定义超时异常的几种方法

    这篇文章主要介绍了详解python中自定义超时异常的几种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-07-07
  • 利用Python如何实时检测自身内存占用

    利用Python如何实时检测自身内存占用

    这篇文章主要介绍了利用Python如何实时检测自身内存占用的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用Python具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2020-05-05
  • C++和python实现阿姆斯特朗数字查找实例代码

    C++和python实现阿姆斯特朗数字查找实例代码

    这篇文章主要给大家介绍了关于C++和python实现阿姆斯特朗数字查找的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-12-12
  • Python 代码在函数中运行得更快的原因解析

    Python 代码在函数中运行得更快的原因解析

    我们知道,python 是一种解释型语言,它会逐行读取并执行代码,小伙伴们可能会有这个疑问:为什么在函数中运行的 Python 代码速度更快,今天这篇文章将会解答大家心中的疑惑
    2023-09-09
  • 关于python并发编程中的协程

    关于python并发编程中的协程

    协程是一种轻量级的并发方式,它是在用户空间中实现的,并不依赖于操作系统的调度,协程可以在同一个线程中实现并发,不需要进行上下文切换,因此执行效率非常高,需要的朋友可以参考下
    2023-04-04
  • 使用Django搭建web服务器的例子(最最正确的方式)

    使用Django搭建web服务器的例子(最最正确的方式)

    今天小编就为大家分享一篇使用Django搭建web服务器的例子(最最正确的方式),具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2019-08-08
  • Python实现微信机器人的方法

    Python实现微信机器人的方法

    这篇文章主要介绍了Python实现微信机器人的方法,非常不错,具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-09-09
  • python+excel接口自动化获取token并作为请求参数进行传参操作

    python+excel接口自动化获取token并作为请求参数进行传参操作

    这篇文章主要介绍了python+excel接口自动化获取token并作为请求参数进行传参操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-11-11
  • 基于python实现删除指定文件类型

    基于python实现删除指定文件类型

    这篇文章主要介绍了基于python实现删除指定文件类型,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-07-07

最新评论