您的位置：首页 > 脚本大全 > > 正文

python多进程创建细节（Python实现多进程的四种方式）

更多时间：2022-01-23 02:27:40 类别：脚本大全浏览量：2970

python多进程创建细节

Python实现多进程的四种方式

方式一: os.fork()

1

2

3

4

5

6

7

8

9

10

11

12 # -*- 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的实例，传入任务执行函数作为参数

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33 # -*- 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方法

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18 # -*- 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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20 # -*- 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()

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对开心学习网的支持。如果你想了解更多相关内容请查看下面相关链接

原文链接：https://blog.csdn.net/topleeyap/article/details/78981848

标签：Python 多进程

上一篇：nginx最佳配置（nginx和lvs各自的优劣以及适合的使用环境）

下一篇：用python查看运行进程（在Python运行时动态查看进程内部信息的方法）

您可能感兴趣

python多进程创建细节（Python实现多进程的四种方式）

python多进程创建细节

热门推荐

排行榜