Python使用monkey.patch_all()解決協程阻塞問題
阿新 • • 發佈:2020-04-16
直接參考以下例項,採用協程訪問三個網站
由於IO操作非常耗時,程式經常會處於等待狀態
比如請求多個網頁有時候需要等待,gevent可以自動切換協程
遇到阻塞自動切換協程,程式啟動時執行monkey.patch_all()解決
# 由於IO操作非常耗時,程式經常會處於等待狀態 # 比如請求多個網頁有時候需要等待,gevent可以自動切換協程 # 遇到阻塞自動切換協程,程式啟動時執行monkey.patch_all()解決 # 首行新增下面的語句即可 from gevent import monkey; monkey.patch_all() import gevent from urllib import request def run_task(url): print("Visit --> %s" % url) try: response = request.urlopen(url) data = response.read() print("%d bytes received from %s." %(len(data),url)) except Exception: print("error") if __name__ == '__main__': urls = ['https://github.com/','https://blog.csdn.net/','https://bbs.csdn.net/'] # 定義協程方法 greenlets = [gevent.spawn(run_task,url) for url in urls] # 新增協程任務,並且啟動執行 gevent.joinall(greenlets) # 檢視執行結果可以發現,三個協程是同時觸發的,但是結束順序不同 # 網頁請求的時間不同,故結束順序不同 # 但是該程式其實只有一個執行緒
輸出結果
Visit --> https://github.com/
Visit --> https://blog.csdn.net/
Visit --> https://bbs.csdn.net/
bytes received from https://blog.csdn.net/.
bytes received from https://bbs.csdn.net/.
bytes received from https://github.com/.Process finished with exit code 0
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。