您的位置:首页 > 编程语言 > Python开发

Python并发执行

2016-02-26 22:28 786 查看
使用Map简化并发的复杂度,生产者消费者模型实在看的头疼

参考这篇帖子说明的很清楚

结合极客学院这位老师视频的参考代码如下

from multiprocessing.dummy import  Pool as ThreadPool
import requests
import time

urls=[]
#定义网页资源集合
for i in range(1,21):
newpage= 'http://tieba.baidu.com/p/3522395718?pn=' +str(i)
urls.append(newpage)

def getsource(url):
html=requests.get(url).text
return html

time1=time.time()
for i in urls:
getsource(i)
time2=time.time()
print('消耗时间%s'%(str(time2-time1)))

time3=time.time()
pool=ThreadPool(8)
doc=pool.map(getsource,urls)
pool.close()
pool.join()
time4=time.time()
print('消耗时间%s'%(str(time4-time3)))


并行化以后加速真是明显:

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  python 并发 极客