多進程:主要運行multiprocessing模塊
import os,timeimport sysfrom multiprocessing import Processclass MyProcess(Process): """docstring for MyProcess""" def __init__(self, arg, callback): super(MyProcess, self).__init__() self.arg = arg self.callback = callback def run(self): self.callback(self.arg)def test(arg): print("子進程{}開始>>> pid={}".format(arg,os.getpid())) for i in range(1,5): sys.stdout.write("子進程{}運行中{}/r".format(arg,i)) sys.stdout.flush() time.sleep(1)def main(): print("主進程開始>>> pid={}".format(os.getpid())) myp=MyProcess(1,test) myp.start() myp2=MyProcess(2,test) myp2.start() myp.join() myp2.join() print("主進程終止")if __name__ == '__main__': main()
線程池:主要運用了未來模塊!下面例子,第一個是正常,第二第線程池,第三個用運行了2個線程池,會排隊
from concurrent.futures import ThreadPoolExecutorimport timedef sayhello(a): print("hello: "+a) time.sleep(2)def main(): seed=["a","b","c"] start1=time.time() for each in seed: sayhello(each) end1=time.time() print("time1: "+str(end1-start1)) start2=time.time() with ThreadPoolExecutor(3) as executor: for each in seed: executor.submit(sayhello,each) end2=time.time() print("time2: "+str(end2-start2)) start3=time.time() with ThreadPoolExecutor(2) as executor1: executor1.map(sayhello,seed) end3=time.time() print("time3: "+str(end3-start3))if __name__ == '__main__': main()
總結
以上所述是小編給大家介紹的python多進程使用及線程池的使用方法代碼詳解,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對武林站長站網站的支持!
新聞熱點
疑難解答