1. 程式人生 > 程式設計 >Python使用monkey.patch_all()解決協程阻塞問題

Python使用monkey.patch_all()解決協程阻塞問題

直接參考以下例項,採用協程訪問三個網站

由於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

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。