【导语】下面是小编为大家收集的python开启多个子进程并行运行的方法(共3篇),仅供参考,欢迎大家阅读,一起分享。
篇1:python开启多个子进程并行运行的方法
作者:work24 字体:[增加 减小] 类型:
这个python代码创建了多个process子进程,创建完成后先start,最后统一join,这样所有子进程会并行执行。
from multiprocessing import Processimport sys, osimport timedef timetask(times): time.sleep(times) print time.localtime()def works(func, arg, worknum): proc_record = [] for i in range(worknum): p = Process(target = func, args = (arg,)) p.start() proc_record.append(p) for p in proc_record: p.join()if __name__ == ‘__main__‘: arg = 5 procs = 4 works(timetask, arg, procs)
希望本文所述对大家的Python程序设计有所帮助,
篇2:python使用Queue在多个子进程间交换数据的方法
作者:work24 字体:[增加 减小] 类型:转载
这篇文章主要介绍了python使用Queue在多个子进程间交换数据的方法,实例分析了Queue实现进程间数据交互的技巧,需要的朋友可以参考下
本文实例讲述了python使用Queue在多个子进程间交换数据的方法,分享给大家供大家参考。具体如下:
这里将Queue作为中间通道进行数据传递,Queue是线程和进程安全的
from multiprocessing import Process, Queuedef f(q): q.put([42, None, ‘hello‘])if __name__ == ‘__main__‘: q = Queue() p = Process(target=f, args=(q,)) p.start() print q.get() # prints “[42, None, ‘hello‘]” p.join()
希望本文所述对大家的Python程序设计有所帮助,
篇3:python基于multiprocessing的多进程创建方法
作者:MaxOmnis 字体:[增加 减小] 类型:转载
这篇文章主要介绍了python基于multiprocessing的多进程创建方法,实例分析了multiprocessing模块操作进程的相关技巧,需要的朋友可以参考下
本文实例讲述了python基于multiprocessing的多进程创建方法,分享给大家供大家参考。具体如下:
import multiprocessingimport timedef clock(interval): while True: print (“the time is %s”% time.time()) time.sleep(interval)if __name__==“__main__”: p = multiprocessing.Process(target=clock,args=(15,)) p.start() #启动进程
定义进程的另一种方法,继承Process类,并实现run方法:
import multiprocessingimport timeclass ClockProcessing(multiprocessing.Process): def __init__(self, intverval): multiprocessing.Process.__init__(self) self.intverval = intverval def run(self): while True:print (“the time is %s”% time.time())time.sleep(self.interval)if __name__==“__main__”: p = ClockProcessing(15) p.start() #启动进程
希望本文所述对大家的Python程序设计有所帮助,
更多推荐
python开启多个子进程并行运行的方法
发布评论