示例1
我們將要請求五個不同的url:
單線程
import timeimport urllib2 defget_responses(): urls=[ ‘http://www.baidu.com', ‘http://www.amazon.com', ‘http://www.ebay.com', ‘http://www.alibaba.com', ‘//www.jb51.net' ] start=time.time() forurlinurls: printurl resp=urllib2.urlopen(url) printresp.getcode() print”Elapsed time: %s”%(time.time()-start) get_responses()
輸出是:
http://www.baidu.com200
http://www.amazon.com200
http://www.ebay.com200
http://www.alibaba.com200
//www.jb51.net200
Elapsed time:3.0814409256
解釋:
url順序的被請求
除非cpu從一個url獲得了回應,否則不會去請求下一個url
網絡請求會花費較長的時間,所以cpu在等待網絡請求的返回時間內一直處于閑置狀態。
多線程
import urllib2import timefrom threading import Thread classGetUrlThread(Thread): def__init__(self, url): self.url=url super(GetUrlThread,self).__init__() defrun(self): resp=urllib2.urlopen(self.url) printself.url, resp.getcode() defget_responses(): urls=[ ‘http://www.baidu.com', ‘http://www.amazon.com', ‘http://www.ebay.com', ‘http://www.alibaba.com', ‘//www.jb51.net' ] start=time.time() threads=[] forurlinurls: t=GetUrlThread(url) threads.append(t) t.start() fortinthreads: t.join() print”Elapsed time: %s”%(time.time()-start) get_responses()
輸出:
//www.jb51.net200
http://www.baidu.com200
http://www.amazon.com200
http://www.alibaba.com200
http://www.ebay.com200
Elapsed time:0.689890861511
解釋:
意識到了程序在執行時間上的提升
我們寫了一個多線程程序來減少cpu的等待時間,當我們在等待一個線程內的網絡請求返回時,這時cpu可以切換到其他線程去進行其他線程內的網絡請求。
我們期望一個線程處理一個url,所以實例化線程類的時候我們傳了一個url。
線程運行意味著執行類里的run()方法。
無論如何我們想每個線程必須執行run()。
為每個url創建一個線程并且調用start()方法,這告訴了cpu可以執行線程中的run()方法了。
我們希望所有的線程執行完畢的時候再計算花費的時間,所以調用了join()方法。
join()可以通知主線程等待這個線程結束后,才可以執行下一條指令。
每個線程我們都調用了join()方法,所以我們是在所有線程執行完畢后計算的運行時間。
關于線程:
cpu可能不會在調用start()后馬上執行run()方法。
你不能確定run()在不同線程建間的執行順序。
對于單獨的一個線程,可以保證run()方法里的語句是按照順序執行的。
這就是因為線程內的url會首先被請求,然后打印出返回的結果。
新聞熱點
疑難解答