如果你打算编写多进程的服务程序,Unix/Linux无疑是正确的选择。由于Windows没有fork调用,难道在Windows上无法用Python编写多进程的程序?

由于Python是跨平台的,自然也应该提供一个跨平台的多进程支持。multiprocessing模块就是跨平台版本的多进程模块。

multiprocessing模块提供了一个Process类来代表一个进程对象,下面的例子演示了启动一个子进程并等待其结束:

#coding=utf-8
from multiprocessing import Process
import os# 子进程要执行的代码
def run_proc(name):print('子进程运行中,name= %s ,pid=%d...' % (name, os.getpid()))if __name__=='__main__':print('父进程 %d.' % os.getpid())p = Process(target=run_proc, args=('test',))print('子进程将要执行')p.start()p.join()print('子进程已结束')

运行结果:

父进程 13227.
子进程将要执行
子进程运行中,name= test ,pid=13228, ppid=13227
子进程已结束

说明

  • 创建子进程时,只需要传入一个执行函数和函数的参数,创建一个Process实例,用start()方法启动,这样创建进程比fork()还要简单。
  • join()方法可以等待子进程结束后再继续往下运行,通常用于进程间的同步。

Process语法结构如下:

Process([group [, target [, name [, args [, kwargs]]]]])

  • target:表示这个进程实例所调用对象;

  • args:表示调用对象的位置参数元组;

  • kwargs:表示调用对象的关键字参数字典;

  • name:为当前进程实例的别名;

  • group:大多数情况下用不到;

Process类常用方法:

  • is_alive():判断进程实例是否还在执行;

  • join([timeout]):是否等待进程实例执行结束,或等待多少秒;

  • start():启动进程实例(创建子进程);

  • run():如果没有给定target参数,对这个对象调用start()方法时,就将执行对象中的run()方法;

  • terminate():不管任务是否完成,立即终止;

Process类常用属性:

  • name:当前进程实例别名,默认为Process-N,N为从1开始递增的整数;

  • pid:当前进程实例的PID值;

实例1

from multiprocessing import Process
import os
from time import sleep# 子进程要执行的代码
def run_proc(name, age, **kwargs):for i in range(10):print('子进程运行中,name= %s,age=%d ,pid=%d...' % (name, age,os.getpid()))print(kwargs)sleep(0.5)if __name__=='__main__':print('父进程 %d.' % os.getpid())p = Process(target=run_proc, args=('test',18), kwargs={"m":20})print('子进程将要执行')p.start()sleep(1)p.terminate()p.join()print('子进程已结束')

运行结果:

父进程 21378.
子进程将要执行
子进程运行中,name= test,age=18 ,pid=21379...
{'m': 20}
子进程运行中,name= test,age=18 ,pid=21379...
{'m': 20}
子进程已结束

实例2

#coding=utf-8
from multiprocessing import Process
import time
import os#两个子进程将会调用的两个方法
def  worker_1(interval):print("worker_1,父进程(%s),当前进程(%s)"%(os.getppid(),os.getpid()))t_start = time.time()time.sleep(interval) #程序将会被挂起interval秒t_end = time.time()print("worker_1,执行时间为'%0.2f'秒"%(t_end - t_start))def  worker_2(interval):print("worker_2,父进程(%s),当前进程(%s)"%(os.getppid(),os.getpid()))t_start = time.time()time.sleep(interval)t_end = time.time()print("worker_2,执行时间为'%0.2f'秒"%(t_end - t_start))#输出当前程序的ID
print("进程ID:%s"%os.getpid())#创建两个进程对象,target指向这个进程对象要执行的对象名称,
#args后面的元组中,是要传递给worker_1方法的参数,
#因为worker_1方法就一个interval参数,这里传递一个整数2给它,
#如果不指定name参数,默认的进程对象名称为Process-N,N为一个递增的整数
p1=Process(target=worker_1,args=(2,))
p2=Process(target=worker_2,name="dongGe",args=(1,))#使用"进程对象名称.start()"来创建并执行一个子进程,
#这两个进程对象在start后,就会分别去执行worker_1和worker_2方法中的内容
p1.start()
p2.start()#同时父进程仍然往下执行,如果p2进程还在执行,将会返回True
print("p2.is_alive=%s"%p2.is_alive())#输出p1和p2进程的别名和pid
print("p1.name=%s"%p1.name)
print("p1.pid=%s"%p1.pid)
print("p2.name=%s"%p2.name)
print("p2.pid=%s"%p2.pid)#join括号中不携带参数,表示父进程在这个位置要等待p1进程执行完成后,
#再继续执行下面的语句,一般用于进程间的数据同步,如果不写这一句,
#下面的is_alive判断将会是True,在shell(cmd)里面调用这个程序时
#可以完整的看到这个过程,大家可以尝试着将下面的这条语句改成p1.join(1),
#因为p2需要2秒以上才可能执行完成,父进程等待1秒很可能不能让p1完全执行完成,
#所以下面的print会输出True,即p1仍然在执行
p1.join()
print("p1.is_alive=%s"%p1.is_alive())

执行结果:

进程ID:19866
p2.is_alive=True
p1.name=Process-1
p1.pid=19867
p2.name=dongGe
p2.pid=19868
worker_1,父进程(19866),当前进程(19867)
worker_2,父进程(19866),当前进程(19868)
worker_2,执行时间为'1.00'秒
worker_1,执行时间为'2.00'秒
p1.is_alive=False

转载于:https://www.cnblogs.com/Paul-watermelon/articles/9724588.html

Python进程学习笔记-multiprocessing模块相关推荐

  1. 简明Python教程学习笔记_3_模块

    模块 如果你想要在其他程序中重用很多函数,那么你该如何编写程序呢?你可能已经猜到了,答案是使用模块.模块基本上就是一个包含了所有你定义的函数和变量的文件.为了在其他程序中重用模块,模块的文件名必须以. ...

  2. Python进程学习笔记-进程创建fork

    1. 进程 VS 程序 编写完毕的代码,在没有运行的时候,称之为程序 正在运行着的代码,就成为进程 进程,除了包含代码以外,还有需要运行的环境等,所以和程序是有区别的. 2. fork( ) Pyth ...

  3. 【Rollo的Python之路】Python 多进程 学习笔记 multiprocessing

    Python 多进程: 由于GIL的存在,python中的多线程并不是真正的多线程,如果想要充分地使用多核CUP的资源,在python里面大部分情况需要使用多进程,Python提供了非常好的多进程包m ...

  4. python中socket模块常用吗_python网络学习笔记——socket模块使用记录

    此文章记录了笔者学习python网络中socket模块的笔记. 建议初次学习socket的读者先读一遍socket模块主要函数的介绍. socket模块的介绍可以参考笔者的前一篇关于socket官方文 ...

  5. python自动化测试学习笔记合集三

    上次我们学到了redis的一些操作,下面来实际运用以下. 这里我们先来学习一下什么是cookie和session. 什么是Cookie 其实简单的说就是当用户通过http协议访问一个服务器的时候,这个 ...

  6. Python学习笔记:第三方模块2

    前言 最近在学习深度学习,已经跑出了几个模型,但Pyhton的基础不够扎实,因此,开始补习Python了,大家都推荐廖雪峰的课程,因此,开始了学习,但光学有没有用,还要和大家讨论一下,因此,写下这些帖 ...

  7. Python学习笔记13_模块

    Python学习笔记13_模块 文章目录 Python学习笔记13_模块 1.导入模块和的方法及使用 2.分层的文件系统中常用的包结构 3.OS 模块 4.sys 模块 5.math 模块 6.ran ...

  8. 8.Python基础学习笔记day8-正则表达式、网络编程、进程与线程

    8.Python基础学习笔记day8-正则表达式.网络编程.进程与线程 一.正则表达式 ''' 1. [1,2,3,4]中任意取3个元素排列: A43 = 4x3x2 = 24itertools.pe ...

  9. Python数据结构学习笔记——队列和双端队列

    目录 一.队列的定义 二.队列 实现步骤分析 三.队列的Python实现代码 四.队列的应用 六人传土豆游戏 五.双端队列的定义 六.双端队列 实现步骤分析 七.双端队列的Python实现代码 八.双 ...

最新文章

  1. Linux c基本知识整理
  2. echarts 默认显示图例_echarts图例组件点击显示功能(默认功能点击消失)
  3. oo0ooo0ooo0oo_OoO的完整形式是什么?
  4. 转:Discuz!NT负载均衡解决方案(HA)之---LVS(Linux Virtual Server)
  5. 机器学习概念 —— 样本距离矩阵
  6. checkbox未赋值时获取value是on_【漏洞分析】关于mysqlconnectorjava连接时的反序列化...
  7. Pentest Wiki Part4 后渗透(二)
  8. python中match方法中r什么意思_什么是pythonre.match函数?(实例解析)
  9. php避免超卖,thinkphp防止超卖
  10. 李宏毅机器学习L6 GAN
  11. spacy中en_core_web_sm安装问题
  12. 【8583】ISO8583各域段的说明
  13. 测试岗位面试题库---支付功能测试思路有哪些?
  14. 免费的跨境浏览器能用吗?目前性价比高的跨境浏览器有哪些?
  15. 现今活跃在信息技术领域的卓越作者--张亚飞新作上市
  16. [Java] lomboz eclipse 下载. 后来安装启动报错,google了好久,未果。放弃之,转Myeclipse
  17. 谦逊编程(翻译整理)
  18. Git系列:管理、撤销以及删除
  19. 聪明的美食家(动态规划)
  20. 软件之外、软件是什么、怎么做软件

热门文章

  1. Keepalived 添加脚本配置监控haproxy方案
  2. ubuntu 软件包降级
  3. centos 6.5 安装 mongodb
  4. C#使用Log4Net记录日志【转】
  5. VB与Java颜色值的转换
  6. T-SQL DML学习笔记
  7. Flutter Mac iOS 环境配置
  8. javascript console 函数详解 js开发调试的利器 浏览:3201|更新:2014-05-30 09:27
  9. TensorFlow 分布式
  10. python99乘法表while翻译_Python学习之while练习--九九乘法表