设为首页 收藏本站
查看: 500|回复: 0

[经验分享] 关于python的多线程问题

[复制链接]

尚未签到

发表于 2017-5-3 09:15:13 | 显示全部楼层 |阅读模式
在网上看到了好多关于python的thread的问题,关于多线程的爬虫,我发现网上一些论坛的代码实际上是单线程的,而我也是刚刚开始搞多线程,这是我的理解,请各位高手多多指教,前面是论坛代码,后面是我自己写的代码,新手,还请指点一下,一起进步~ DSC0000.gif

论坛代码(自己研究了一下,大体是这样):

#encoding:UTF-8
importthreading
importurllib,urllib2
importQueue
importbs4
frombs4importBeautifulSoup
importtime

hosts=['http://www.baidu.com','http://www.weibo.com','http://www.renren.com']
queue=Queue.Queue(0);
out_queue=Queue.Queue(0)

classContentThread(threading.Thread):
def__init__(self,queue,out_queue):
threading.Thread.__init__(self)
self.queue=queue
self.out_queue=out_queue
defrun(self):
whileTrue:
host=self.queue.get()
url=urllib.urlopen(host)
chunk=url.read()
self.out_queue.put(chunk)
self.queue.task_done()

classmatch(threading.Thread):
def__init__(self,out_queue):
threading.Thread.__init__(self)
self.out_queue=out_queue
defrun(self):
whileTrue:
chunk=self.out_queue.get()
soup=BeautifulSoup(chunk)
printsoup.findAll(['title'])
printself.name
self.out_queue.task_done()
start=time.time()
defmain():
t=ContentThread(queue,out_queue)
t.setDaemon(True)
t.start()
foriinhosts:
queue.put(i)
dt=match(out_queue)
dt.setDaemon(True)
dt.start()
queue.join()
out_queue.join()

if__name__=='__main__':
main()
print'爬虫耗时:%s秒'%(time.time()-start)


这个代码在task_done()之后加上time.sleep(10)会有明显的堵塞情况。输出threadname也是显示相同的线程名字。
这是是我写的多线程爬虫:

#encoding:UTF-8
importthreading
importurllib,urllib2
importQueue
importbs4
frombs4importBeautifulSoup
importtime

queue=Queue.Queue(0)
hosts=['http://www.baidu.com','http://www.weibo.com','http://www.renren.com']
classMyThread(threading.Thread):
def__init__(self):
threading.Thread.__init__(self)
self.queue=queue
#self.out_queue=out_queue
defrun(self):
globalqueue
host=self.queue.get()
printself.name
url=urllib.urlopen(host)
chunk=url.read()
soup=BeautifulSoup(chunk)
printsoup.findAll(['title'])
print'爬虫耗时:%s秒'%(time.time()-start)
#printhost
#printqueue.qsize()

start=time.time()
defhost():
foriinhosts:
t=MyThread()
t.start()
msg=str(i)
globalqueue
queue.put(str(i))
printmsg
#print"ElapsedTime:%s"%(time.time()-start)
if__name__=='__main__':
host()


这个在输出时间之后再sleep不会出现堵塞情况,输出threadname也是显示不同的线程名字

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-372352-1-1.html 上篇帖子: [Python] 函数lambda(), filter(), map(), reduce() 下篇帖子: python基础知识总结---数据结构---序列
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表