苍井空左脚消失,wow玉猫,在线公司测名
多进程:主要运行multiprocessing模块
import os,time import sys from multiprocessing import process class 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 threadpoolexecutor import time def 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多进程使用及线程池的使用方法代码详解,希望对大家有所帮助
如对本文有疑问,请在下面进行留言讨论,广大热心网友会与你互动!! 点击进行留言回复
Python爬虫:Request Payload和Form Data的简单区别说明
浅谈Python中threading join和setDaemon用法及区别说明
Python3-异步进程回调函数(callback())介绍
python继承threading.Thread实现有返回值的子类实例
Python中使用threading.Event协调线程的运行详解
网友评论