对Python中创建进程的两种方式以及进程池详解_Python

对Python中创建进程的两种方式以及进程池详解

2021-05-15 00:13KUNLI7 Python

今天小编就为大家分享一篇对Python中创建进程的两种方式以及进程池详解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

在Python中创建进程有两种方式，第一种是：

				?

									from multiprocessing import Process

									import time

									def test():

									 while True:

									  print('---test---')

									  time.sleep(1)

									if __name__ == '__main__':

									 p=Process(target=test)

									 p.start()

									 while True:

									  print('---main---')

									  time.sleep(1)

上面这段代码是在windows下跑的，通过Process类可以创建一个进程对象，然后p.start()即可开启进程，test函数是你想进程实现的功能。

第二种方式是：

				?

									from multiprocessing import Process

									import time

									class MyNewProcess(Process):

									 def run(self):

									  while True:

									   print('---1---')

									   time.sleep(1)

									if __name__=='__mian__':

									 p = MyNewProcess()

									 # 调用p.start()方法，p会先去父类中寻找start()，然后在Process的start方法中调用run方法

									 p.start()

									 while True:

									  print('---Main---')

									  time.sleep(1)

这里是第二种创建进程的方式，通过子类继承Process类，子类中必须有run方法，里面实现进程功能，创建子类对象之后，调用对象的start方法。

下面来说一下进程池，就是实现已经创建好的进程

				?

									# 进程池

									from multiprocessing import Pool

									import os

									import random

									import time

									def worker(num):

									 for i in range(5):

									  print('===pid=%d==num=%d='%(os.getpid(),num))

									  time.sleep(1)

									# 3表示进程池中最多有三个进程一起执行

									pool=Pool(3)

									for i in range(10):

									 print('---%d---'%i)

									 # 向进程中添加任务

									 # 注意：如果添加的任务数量超过了进程池中进程的个数的话，那么就不会接着往进程池中添加，如果还没有执行的话，他会等待前面的进程结束，然后在往

									 # 进程池中添加新进程

									 pool.apply_async(worker,(i,))

									pool.close() # 关闭进程池

									pool.join() # 主进程在这里等待，只有子进程全部结束之后，在会开启主线程