Python实现多进程的四种方式实现多进程的四种方式
今天小编就为大家分享一篇关于Python实现多进程的四种方式，小编觉得内容挺不错的，现在分享给大家，具
有很好的参考价值，需要的朋友一起跟随小编来看看吧
方式一方式一: 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
评论0