python多进程实现的几种方式

方法一：os.fork()

"""
pid.fork()
    1.只在unix系统中生效，window系统中无效
　 2.for函数调用一次，返回两次：在父进程中返回值为子进程的id，在子进程中返回值为0
"""
import os
pid=os.fork()
if pid==0:
    print ("子进pid={pid}，父进程ppid={ppid}".format(pid=os.getpid(),ppid=os.getppid))
else:
   print ("子进pid={pid}，父进程ppid={ppid}".format(pid=pid,ppid=os.getpid))

方法二：使用mutiprocessing模块：创建process的实例，传入任务执行函数作为参数

"""
process常用属性和方法：
　　name：进程名
　　pid：进程id
　　run（），自定义子类时的覆写
　　start（），开启进程
　　join（timeout=None），阻塞进程
　　terminate（），终止进程
　　is_alive（），判断进程是否存活
"""
import os,time
from mutiprocess import Process
def work():
　　print("子进程执行中，，，pid={0},ppid={ppid}".format(pid=os.getpid(),ppid=os.getppid()))
　　time.sleep(2)
　　print("子进程终止中，，，pid={0}".format(pid=os.getpid()))
def main():
　　print("主进程执行中，pid={0}".format(os.getpid))
　　ps=[]
　　for i in range(2):
　　　　p=Process(target=work,name="work"+str(i),args=())
　　　　ps.append()
　　for i in range(2):
　　　　ps[i].start()
      for i in range(2):
             ps[i].join()
if __name__="__main__":
　　main()

方法三：使用mutiprocessing模块：派生Process的子类，重写run方法

import os,time
from mutiprocess import Process
class MyProcess(Process):
　　def __init__(self):
　　　　Process.__init__(self)
　　def run(self):
　　　　print("子进程开始>>> pid={0},ppid={1}".format(os.getpid(),os.getppid()))
　　　　time.sleep(2)
　　　　print("子进程终止>>> pid={}".format(os.getpid()))
def main():
　　print("主进程开始>>> pid={}".format(os.getpid()))
　　myp=MyProcess()
　　myp.start()
　　myp.join()
　　print("主进程终止")
if __name__="__main__":
　　main()

方法四：使用进程池

import os,time
from multiprocessing import Pool
def worker(arg):    
　　print("子进程开始执行>>> pid={},ppid={},编号{}".format(os.getpid(),os.getppid(),arg))    
　　time.sleep(0.5)    
　　print("子进程终止>>> pid={},ppid={},编号{}".format(os.getpid(),os.getppid(),arg))
def main():    
　　print("主进程开始执行>>> pid={}".format(os.getpid()))    
　　ps=Pool(5)    
　　for i in range(10):        
　　　　# ps.apply(worker,args=(i,))          # 同步执行        
　　　　ps.apply_async(worker,args=(i,))  # 异步执行     
　　　　# 关闭进程池，停止接受其它进程    
　　　　ps.close()    # 阻塞进程    
　　　　ps.join()   
　　 print("主进程终止")
if __name__ == '__main__':   
　　 main()