Python 进程的创建 - multiprocessing

2019-05-31 10:50:58 浏览数 (1)

进程的创建-multiprocessing

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

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

代码语言:javascript复制
[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()

执行如下:

代码语言:javascript复制
[root@server01 process]# python test.py 
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群
第二个人:胖子老板来包芙蓉王
第一个人:胖子老板来包蓝利群

从上面的执行来看,两个while循环买烟的操作并没有被阻塞,例如不需要第一个循环执行完毕,才能执行第二个循环。而是直接可以两个循环同时进行。

  • 创建子进程时,只需要传入一个执行函数和函数的参数,创建一个Process实例,用start()方法启动。 这个操作跟启动线程是一样的。

进程pid

打印上面代码的主进程和子进程的pid看看。

代码语言:javascript复制
# -*- 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()

执行如下:

代码语言:javascript复制
[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(进程号)

给子进程指定的函数传递参数 - 买多少钱的烟

代码语言:javascript复制
# -*- 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()

执行如下:

代码语言:javascript复制
[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}

进程间不共享全局变量

定义一个全局变量,使用两个进程分别修改,然后分别打印,查看是否相同。 例如:定义一包烟的名称,两个进程,一个修改,一个不修改,分开打印。

代码语言:javascript复制
# -*- 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()

执行如下:

代码语言:javascript复制
[root@server01 process]# python test.py 
打印主进程的pid=2014
主进程开始执行:我要买蓝利群
主进程结束执行:我要买蓝利群
第一个人:胖子老板来包芙蓉王
第二个人: 胖子老板来包 蓝利群
第二个人: 胖子老板来包 蓝利群
第一个人:胖子老板来包芙蓉王
第一个人:胖子老板来包芙蓉王
第二个人: 胖子老板来包 蓝利群
[root@server01 process]# 

可以从结果中看出,第一个进程修改了ciggite_name为芙蓉王,但是却不影响主进程和子进程的值,依然是蓝利群。 说明子进程并不能共享修改全局变量,这一点与线程是有区别的。

0 人点赞