協(xié)程【是一個單線程】，又稱微線程，纖程。英文名Coroutine。

一句話說明什么是協(xié)程：協(xié)程是一種用戶態(tài)的輕量級線程【程序員自己去切換線程】

協(xié)程條件：

必須在只有一個單線程里實現(xiàn)并發(fā)

修改共享數(shù)據(jù)不需加鎖

用戶程序里自己保存多個控制流的上下文棧

一個協(xié)程遇到IO操作自動切換到其它協(xié)程

協(xié)程原理：

協(xié)程擁有自己的寄存器上下文和棧。協(xié)程調(diào)度切換時，將寄存器上下文和棧保存到其他地方，在切回來的時候，恢復(fù)先前保存的寄存器上下文和棧。因此：

協(xié)程能保留上一次調(diào)用時的狀態(tài)（即所有局部狀態(tài)的一個特定組合），每次過程重入時，就相當于進入上一次調(diào)用的狀態(tài)，換種說法：進入上一次離開時所處邏輯流的位置。

協(xié)程的好處【Nginx就是協(xié)程】：

無需線程上下文切換的開銷【單線程】

無需原子操作鎖定及同步的開銷

"原子操作(atomic operation)是不需要synchronized"，所謂原子操作是指不會被線程調(diào)度機制打斷的操作；這種操作一旦開始，就一直運行到結(jié)束，中間不會有任何 context switch （切換到另一個線程）。原子操作可以是一個步驟，也可以是多個操作步驟，但是其順序是不可以被打亂，或者切割掉只執(zhí)行部分。視作整體是原子性的核心。

方便切換控制流，簡化編程模型

高并發(fā)+高擴展性+低成本：一個CPU支持上萬的協(xié)程都不是問題。所以很適合用于高并發(fā)處理

協(xié)程缺點：

無法利用多核資源【可以通過多進程實現(xiàn)多核利用】：協(xié)程的本質(zhì)是個單線程,它不能同時將單個CPU 的多個核用上,協(xié)程需要和進程配合才能運行在多CPU上.當然我們?nèi)粘Ｋ帉懙慕^大部分應(yīng)用都沒有這個必要，除非是cpu密集型應(yīng)用。

進行阻塞（Blocking）操作（如IO時）會阻塞掉整個程序

最底層實際上使用yield實現(xiàn)協(xié)程操作

import time import queue def consumer(name):print("--->starting eating baozi...")while True:new_baozi = yieldprint("[%s] is eating baozi %s" % (name, new_baozi))# time.sleep(1) def producer():r = con.__next__()r = con2.__next__()n = 0while n < 5:n += 1con.send(n)con2.send(n)print("\033[32;1m[producer]\033[0m is making baozi %s" % n) if __name__ == '__main__':con = consumer("c1")con2 = consumer("c2")p = producer()

gevent

安裝gevent

Gevent 介紹

???? Gevent 是一個第三方庫，可以輕松通過gevent實現(xiàn)并發(fā)同步或異步編程，在gevent中用到的主要模式是Greenlet, 它是以C擴展模塊形式接入Python的輕量級協(xié)程。 Greenlet全部運行在主程序操作系統(tǒng)進程的內(nèi)部，但它們被協(xié)作式地調(diào)度。

import gevent import time def func1():print(time.ctime(), '\033[31;1mA-->B...\033[0m')gevent.sleep(2) # 模擬IO阻塞print(time.ctime(), '\033[31;1mA-->B...\033[0m') def func2():print(time.ctime(), '\033[32;1mB-->A...\033[0m')gevent.sleep(1) # 模擬IO阻塞print(time.ctime(), '\033[32;1mB-->A...\033[0m') # 一個線程自己切換，共耗時2秒，以最大的為準 gevent.joinall([gevent.spawn(func1),gevent.spawn(func2), ])

?

?

Greenlet

greenlet是一個用C實現(xiàn)的協(xié)程模塊，相比與python自帶的yield，它可以使你在任意函數(shù)之間隨意切換，而不需把這個函數(shù)先聲明為generator

# -*- coding:utf-8 -*- from greenlet import greenlet def test1():print(12)gr2.switch()print(34)gr2.switch() def test2():print(56)gr1.switch()print(78) gr1 = greenlet(test1) gr2 = greenlet(test2) gr1.switch()

協(xié)程爬蟲

遇到IO阻塞時會自動切換任務(wù)[協(xié)程爬蟲]

from gevent import monkey; monkey.patch_all() # 監(jiān)聽IO阻塞 import time import gevent from urllib.request import urlopen start = time.time() def f(url, name):print('GET: %s' % url)resp = urlopen(url)data = resp.read()with open(name+'.thml', 'wb') as f:f.write(data)print('%d bytes received from %s.' % (len(data), url)) gevent.joinall([gevent.spawn(f, 'https://www.python.org/', 'python'), # 就是這種格式傳遞參數(shù)gevent.spawn(f, 'https://www.yahoo.com/', 'yahoo'),gevent.spawn(f, 'https://github.com/', 'github'), ]) end = time.time() print('gevent 耗時', str(end-start))

?

?

?

?

?

?

?

?

?

【更多參考】

http://www.cnblogs.com/alex3714/articles/5248247.html

轉(zhuǎn)載于:https://www.cnblogs.com/ftl1012/p/9384297.html

總結(jié)

以上是生活随笔為你收集整理的Python学习---协程 1226的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。