建立进程池,线程池:
进程池from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor import time,random,os def task(n): print(‘%s is running‘%os.getpid()) time.sleep(5) return n**2 if __name__ == ‘__main__‘: p = ProcessPoolExecutor() l=[] start=time.time() for i in range(20): obj=p.submit(task,i) l.append(obj) p.shutdown() print([obj.result()for obj in l]) print(time.time()-start)
线程池from concurrent.futures import ThreadPoolExecutor,ProcessPoolExecutor import time,random,os def task(n): print(‘%s is running‘%os.getpid()) time.sleep(5) return n**2 if __name__ == ‘__main__‘: p = ThreadPoolExecutor() l=[] start=time.time() for i in range(20): obj=p.submit(task,i) l.append(obj) p.shutdown() print([obj.result()for obj in l]) print(time.time()-start)
在这里我要声明一下,多进程,以及多线程,进程池,线程池:
多进程,简单来来讲就是好多个进程在做事,当进行I/O操作的是时候,一个进程去做这件事,其他进程就只能等着,只有这个进程做完了,其他进程才能去做,就和上厕所是一样,一个人上厕所,其他人都得等着,在这里又出现一个进程池,所谓的进程池就是用来规范多进程的,不理解吧,(这样多进程用于计算的时候,比如说你有好多的进程2000000个,这么多都在计算是不是很可怕,这里添加一个进程池约束一下是不是就完美了,里面的计算完了,外面的再进来计算)
多线程,怎么讲呢,就是在一个进程里面,所以这个进程里面的资源对于线程来说就是共享的啦,多线程常用于I/O操作,
时间: 2024-10-13 20:57:50