Python 进程的创建 - multiprocessing（python下载安装教程）

Python 进程的创建 - multiprocessing（python下载安装教程）

进程的创建-multiprocessing

multiprocessing模块就是跨平台版本的多进程模块，提供了一个Process类来代表一个进程对象，这个对象可以理解为是一个独立的进程，可以执行另外的事情

2个while循环一起执行，同时两人循环买烟

[root@server01 process]# vim test.py # -*- coding:utf-8 -*-from multiprocessing import Processimport timedef 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 Processimport timeimport osdef 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 Processimport timeimport osdef 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 Processimport timeimport osciggite_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为芙蓉王，但是却不影响主进程和子进程的值，依然是蓝利群。 说明子进程并不能共享修改全局变量，这一点与线程是有区别的。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。