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

时间:2021-05-22

在Python中创建进程有两种方式,第一种是:

from multiprocessing import Processimport 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 Processimport 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 Poolimport osimport randomimport 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() # 主进程在这里等待,只有子进程全部结束之后,在会开启主线程

大家可以看到在Pool方法就是创建了一个进程池,3表示创建进程数,通过pool.apply_async( )将子进程添加到进程池中,pool.close( )表示关闭进程池,一定要添加join函数,否则主进程直接崩了,看不到进程池中子进程的现象。

以上这篇对Python中创建进程的两种方式以及进程池详解就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。

声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

相关文章