協程
1、什么是協程
行程:資源單位
執行緒:執行單位
協程:是單執行緒下的并發,又稱微執行緒,纖程,即單執行緒可以通過協程來實作并發,
PS:協程是一種用戶態的輕量級執行緒,即協程是由用戶程式自己控制調度的,
2、協程的優缺點
優點:
1)協程的切換開銷更小,屬于程式級別的切換,作業系統完全感知不到,因而更加輕量級
2)單執行緒內就可以實作并發的效果,最大限度地利用cpu
缺點:
1)協程的本質是單執行緒下,無法利用多核,可以是一個程式開啟多個行程,每個行程內開啟多個執行緒,每個執行緒內開啟協程
2)協程指的是單個執行緒,因而一旦協程出現阻塞,將會阻塞整個執行緒
3、協程的特點
1)必須在只有一個單執行緒里實作并發
2)修改共享資料不需加鎖
附加:一個協程遇到IO操作自動切換到其它協程(gevent模塊)
4、gevent模塊
gevent模塊是一個第三方模塊,需要下載安裝gevent庫
pip3 install gevent
用法:
g1 = gevent.spawn(函式名, 引數1, 引數2, 引數3...) # 創建一個協程物件
gevent.joinall([g1, g2, g3]) # 遇到IO阻塞時會自動在 [g1, g2, g3] 中切換任務
monkey.patch_all() # 必須放到被打補丁者的前面,如time,socket模塊之前(可以記憶成要用gevent,需要將from gevent import monkey和monkey.patch_all()放到檔案的開頭)
代碼演示:
from gevent import monkey # 猴子補丁 monkey.patch_all() # 監聽所有的任務是否有IO操作,如果有就切換,必須寫在最上面,這句話后面的所有阻塞全部能夠被識別到 from gevent import spawn # spawn(函式名, 引數1, 引數2, 引數3...) from gevent import joinall # 等同于start和join的作用 import time def task1(): print("start from task1...") time.sleep(1) print("end from task1...") def task2(): print("start from task2...") time.sleep(3) print("end from task2...") def task3(): print("start from task3...") time.sleep(5) print("end from task3...") if __name__ == '__main__': start_time = time.time() # 創建協程物件 sp1 = spawn(task1) sp2 = spawn(task2) sp3 = spawn(task3) # sp1.start() # sp2.start() # sp3.start() # sp1.join() # sp2.join() # sp3.join() # 使用joinall()方法 joinall([sp1, sp2, sp3]) # 等同于start和join的作用 end_time = time.time() print(f"執行時間為 {end_time - start_time}")
執行結果:
start from task1... start from task2... start from task3... end from task1... end from task2... end from task3... 執行時間為 5.030768394470215
行程和執行緒的任務切換是由作業系統自行切換的,自己不能控制
協程是通過自己的程式(代碼)來進行切換的,自己能夠控制,只有遇到協程模塊能夠識別的IO操作的時候,程式才會進行任務切換,實作并發效果,如果所有程式都沒有IO操作,那么就基本屬于串行執行了
轉載請註明出處,本文鏈接:https://www.uj5u.com/houduan/206924.html
標籤:Python
上一篇:多執行緒和多行程使用對比
