关于python中的多进程模块multiprocessing

这里的提到的那个是多进程管理的包, 它主要的任务也就是提供多进程的这种功能, 而不是多线程, 然后在使用的过程中比较多见的大概就是Pipe这两个类的结合, 具体可以参考下面展示的这段代码内容:#!/usr/bin/env pythonfrom multiprocessing import Process,Pipedef fun(pipe,x):pipe.send(hello,x)reciver,sender Pipe()proc Process(targetfun,args(sender,kel,)) #传递参数为sender其实传递的是reciver也是可以的proc.start()print reciver.recv()proc.join()print reciver.recv() #在等待接收在创建Pipe对象的时候, 可以使用两个部分, 其中一个部分是专门用来接收的, 另一个部分则是专门用来发送的, 但是根据上文所述构造对象的示例情况, 可以看到这两个部分实际上都同时具备可以进行发送以及可以进行接收的功能。执行所获得的结果, 呈现以下这般情况。[rootpython 55]# python simplePipe.pyhello,kel在发送数据的时候, 发送的内容为kel, 此时返回的结果为hello, kel。在执行创建Pipe这个动作的时候, 最终返回回来的结果是一个由一对对象组成的集合, 具体的样子就像下面这样展示出来的情况一样。 from multiprocessing import Pipe pPipe() p(, )用户所返回的数据信息, 全都是既可以读取又能够进行写入操作的。在多进程管理之中, 主要的作用是用来创建进程, 进而去构建出多进程的运行环境, 这个意思就是指代上面所提到的那段示例代码。你可以利用start这种方法来实现启动这个进程的动作, 接着采用join这种方式来达到结束掉该进程的目的。语法上的结果就是下面这些情况。class multiprocessing.Process(groupNone, targetNone, nameNone, args(), kwargs{})一般情况下面, 需要被指定的参数的样子是那样儿的, 它被表示成了一个函数, 话说回来, 这个大函数, 必须是那种能够直接调用的类型, 至于那个表示为args的部分, 说的是这个参数, 它的格式, 是一个元组的形状, 请注意, 一旦碰到了一个参数的情况, 你非得要把那个逗号给写出来不可, 为啥子,就是为了把它标识成了一个名叫tuple的东西。 from multiprocessing import Process import time def kel():... time.sleep(20)... procProcess(targetkel,args()) proc.pid #进程未开始的时候pid为None proc.is_alive() #查看进程是否活动False proc.start() #进程开始运行 proc.pid6117 proc.is_alive()True proc.is_alive() #程序执行完毕进程自动关闭False proc.join()当咱们深入到操作系统的这一层级的时, 是可以直接拿到进程的相关信息的, 具体情况你可以看一下下面这个例子:[rootpython ~]# ps -ef|grep 6117root 6117 6114 0 09:36 pts/1 00:00:00 pythonroot 6121 6091 0 09:36 pts/3 00:00:00 grep 6117Pipe这个语法的具体展示形式是下面这样的。multiprocessing.Pipe([duplex])通过使用Pipe和配合, 能够启动一个进程, 并获取该函数执行程序后所产生的返回性质的结果信息。当存在需要多个进程这种情形的时候, 你可以运用以下所呈现出来的方式。from multiprocessing import Pipe,Processclass Pool(object):classmethoddef spawn(cls,f):def fun(pipe,x):pipe.send(f(x))pipe.close()return funclassmethoddef partmap(cls,f,X):pipe [Pipe() for x in X]proc [Process(targetcls.spawn(f),args(c,x)) for x,(p,c) in zip(X,pipe)][p.start() for p in proc][p.join() for p in proc]return [p.recv() for p,m in pipe]def kel(x):return hello,,xprint Pool.partmap(kel,[kel,smile])执行结果如下[(hello,, kel), (hello,, smile)]主要做的事情是开启多个进程来执行相关的函数, 在这些过程当中使用到了闭包, 其主要目的就是为了执行这个函数, 并且通过管道的方式来传递相关的消息。