Python 进程的创建 - multiprocessing
进程的创建-multiprocessing
multiprocessing模块就是跨平台版本的多进程模块,提供了一个Process类来代表一个进程对象,这个对象可以理解为是一个独立的进程,可以执行另外的事情
2个while循环一起执行,同时两人循环买烟
[root@server01 process]# vim test.py
# -*- coding:utf-8 -*-
from multiprocessing import Process
import time
def bug_ciggite():
while True:
print("第一个人:胖子老板来包蓝利群")
time.sleep(1)
def main():
# 第一个人开启一个子进程来执行循环买烟的操作
p = Process(target=bug_ciggite)
p.start()
# 第二个人来跟胖子老板买烟
while True:
print("第二个人:胖子老板来包芙蓉王")
time.sleep(1)
if __name__ == "__main__":
main()
执行如下:
[root@server01 process]# python test.py
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
从上面的执行来看,两个while循环买烟的操作并没有被阻塞,例如不需要第一个循环执行完毕,才能执行第二个循环。而是直接可以两个循环同时进行。
- 创建子进程时,只需要传入一个执行函数和函数的参数,创建一个Process实例,用start()方法启动。 这个操作跟启动线程是一样的。
进程pid
打印上面代码的主进程和子进程的pid看看。
# -*- coding:utf-8 -*-
from multiprocessing import Process
import time
import os
def bug_ciggite():
while True:
print("第一个人:胖子老板来包蓝利群")
print("打印子进程的pid=%d" % os.getpid())
time.sleep(1)
def main():
print("打印主进程的pid=%d" % os.getpid())
# 第一个人开启一个子进程来执行循环买烟的操作
p = Process(target=bug_ciggite)
p.start()
# 第二个人来跟胖子老板买烟
while True:
print("第二个人:胖子老板来包芙蓉王")
time.sleep(1)
if __name__ == "__main__":
main()
执行如下:
[root@server01 process]# python test.py
打印主进程的pid=1864
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
打印子进程的pid=1865
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
打印子进程的pid=1865
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
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(进程号)
给子进程指定的函数传递参数 - 买多少钱的烟
# -*- coding:utf-8 -*-
from multiprocessing import Process
import time
import os
def bug_ciggite(name,price,**kwargs):
while True:
print("第一个人:胖子老板来包蓝利群")
print("打印子进程的pid=%d" % os.getpid())
print("买包%d的%s" % (price,name))
print(kwargs)
time.sleep(1)
def main():
print("打印主进程的pid=%d" % os.getpid())
# 第一个人开启一个子进程来执行循环买烟的操作
p = Process(target=bug_ciggite,args=('蓝利群',17),kwargs={"m":20})
p.start()
# 第二个人来跟胖子老板买烟
while True:
print("第二个人:胖子老板来包芙蓉王")
time.sleep(1)
if __name__ == "__main__":
main()
执行如下:
[root@server01 process]# python test.py
打印主进程的pid=1904
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
打印子进程的pid=1905
买包17的蓝利群
{'m': 20}
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
打印子进程的pid=1905
买包17的蓝利群
{'m': 20}
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
打印子进程的pid=1905
买包17的蓝利群
{'m': 20}
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
打印子进程的pid=1905
买包17的蓝利群
{'m': 20}
进程间不共享全局变量
定义一个全局变量,使用两个进程分别修改,然后分别打印,查看是否相同。 例如:定义一包烟的名称,两个进程,一个修改,一个不修改,分开打印。
# -*- coding:utf-8 -*-
from multiprocessing import Process
import time
import os
ciggite_name = "蓝利群"
def bug_ciggite1():
ciggite_name = '芙蓉王'
for i in range(3):
print("第一个人:胖子老板来包%s" % ciggite_name )
time.sleep(1)
def bug_ciggite2():
for i in range(3):
print("第二个人: 胖子老板来包 %s" % ciggite_name)
time.sleep(1)
def main():
print("打印主进程的pid=%d" % os.getpid())
print("主进程开始执行:我要买%s" % ciggite_name)
# 第一个人开启一个子进程来执行循环买烟的操作
p1 = Process(target=bug_ciggite1)
p1.start()
# 第二个人开启子进程买烟
p2 = Process(target=bug_ciggite2)
p2.start()
print("主进程结束执行:我要买%s" % ciggite_name)
if __name__ == "__main__":
main()
执行如下:
[root@server01 process]# python test.py
打印主进程的pid=2014
主进程开始执行:我要买蓝利群
主进程结束执行:我要买蓝利群
第一个人:胖子老板来包芙蓉王
第二个人: 胖子老板来包 蓝利群
第二个人: 胖子老板来包 蓝利群
第一个人:胖子老板来包芙蓉王
第一个人:胖子老板来包芙蓉王
第二个人: 胖子老板来包 蓝利群
[root@server01 process]#
可以从结果中看出,第一个进程修改了ciggite_name为芙蓉王,但是却不影响主进程和子进程的值,依然是蓝利群。 说明子进程并不能共享修改全局变量,这一点与线程是有区别的。
- 【编程基础】System.arraycopy()和 Arrays.copyOf()
- 移动端 模拟手机联系人触摸A~Z导航
- 谈谈个人网站的建立(七)—— 那些建站必备的插件
- 【美团技术团队博客】Linux资源管理之cgroups简介
- 谈谈个人网站的建立(六)—— 数据库同步
- Javascript解析机制 执行机制
- Tomcat9源码——编译环境搭建
- 谈谈个人网站的建立(五)—— 小集群的部署
- 跟Google学写代码--Chromium/base--cpu源码学习及应用
- Spring项目路径
- 跟Google学写代码--Chromium/base--stl_util源码学习及应用
- libphonenumber--windows上编译libphonenumber.lib以及使用(C++、VS2015)
- querySelector与querySelectorAll
- 【技术博客】Spark性能优化指南——基础篇
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- JVM垃圾回收机制和算法详解
- 使用 zabbix 监控 tomcat(包含jvm监控)
- Python open 读和写
- Linux系统SSH服务之 sshkey密钥认证实战
- Redis工作中常用命令,看这一篇就够了
- String、StringBuffer、StringBuiler深入分析,看这一篇就够了
- Windows安装pip方法
- 通过jvm字节码研究Synchronized
- 学synchronized锁升级过程,吊打面试官
- jvm启动加载类的全过程,全网最全一篇,告诉你什么是双亲委派机制
- sonar+Jenkins 构建代码质量自动化分析平台
- 几百行代码,实现了微信群聊,神奇!
- 深入解析==与equals()区别
- 工作中常用的十款idea插件
- Linux系统rsync数据同步服务介绍