绑定完请刷新页面
取消
刷新

分享好友

×
取消 复制
Python实现多进程的四种方式!详细介绍
2019-10-08 10:46:50

废话不多说,直接看!

方式一: os.fork()


# -*- coding:utf-8 -*-
"""
pid=os.fork()
 1.只用在Unix系统中有效,Windows系统中
 2.fork函数调用一次,返回两次:在父进程中返回值为子进程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()))


方式二: 使用multiprocessing模块: 创建Process的实例,传入任务执行函数作为参数


# -*- coding:utf-8 -*-
"""
Process常用属性与方法:
 name:进程名
 pid:进程id
 run(),自定义子类时覆写
 start(),开启进程
 join(timeout=None),阻塞进程
 terminate(),终止进程
 is_alive(),判断进程是否存活
"""
import os,time
from multiprocessing import Process
def worker():
 print("子进程执行中>>> pid={0},ppid={1}".format(os.getpid(),os.getppid()))
 time.sleep(2)
 print("子进程终止>>> pid={0}".format(os.getpid()))
def main():
 print("主进程执行中>>> pid={0}".format(os.getpid()))
 ps=[]
 # 创建子进程实例
 for i in range(2):
 p=Process(target=worker,name="worker"+str(i),args=())
 ps.append(p)
 # 开启进程
 for i in range(2):
 ps[i].start()
 # 阻塞进程
 for i in range(2):
 ps[i].join()
 print("主进程终止")
if __name__ == '__main__':
 main()


方式三: 使用multiprocessing模块: 派生Process的子类,重写run方法


# -*- coding:utf-8 -*-
import os,time
from multiprocessing 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()


方式四: 使用进程池Pool

# -*- coding:utf-8 -*-
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()


分享好友

分享这个小栈给你的朋友们,一起进步吧。

应用开发
创建时间:2020-06-17 15:31:04
应用软件开发是指使用程序语言C#、java、 c++、vb等语言编写,主要是用于商业、生活应用的软件的开发。
展开
订阅须知

• 所有用户可根据关注领域订阅专区或所有专区

• 付费订阅:虚拟交易,一经交易不退款;若特殊情况,可3日内客服咨询

• 专区发布评论属默认订阅所评论专区(除付费小栈外)

技术专家

查看更多
  • 栈栈
    专家
戳我,来吐槽~