深入理解python協程
協程擁有自己的寄存器和棧。協程調度切換的時候,將寄存器上下文和棧都保存到其他地方,在切換回來的時候,恢復到先前保存的寄存器上下文和棧,因此:協程能保留上一次調用狀態,每次過程重入時,就相當于進入上一次調用的狀態。
協程的好處:
1.無需線程上下文切換的開銷(還是單線程) 2.無需原子操作(一個線程改一個變量,改一個變量的過程就可以稱為原子操作)的鎖定和同步的開銷 3.方便切換控制流,簡化編程模型 4.高并發+高擴展+低成本:一個cpu支持上萬的協程都沒有問題,適合用于高并發處理缺點:
1.無法利用多核的資源,協程本身是個單線程,它不能同時將單個cpu的多核用上,協程需要和進程配合才能運用到多cpu上(協程是跑在線程上的) 2.進行阻塞操作時會阻塞掉整個程序:如io二、了解協程的過程2.1、yield工作原理從語法上來看,協程和生成器類似,都是定義體中包含yield關鍵字的函數。
yield在協程中的用法:
在協程中yield通常出現在表達式的右邊,例如:datum = yield,可以產出值,也可以不產出--如果yield關鍵字后面沒有表達式,那么生成器產出None。 在協程中yield也可能從調用方接受數據,調用方是通過send(datum)的方式把數據提供給協程使用,而不是next(...)函數,通常調用方會把值推送給協程。 協程可以把控制器讓給中心調度程序,從而激活其他的協程。所以總體上在協程中把yield看做是控制流程的方式。
先通過一個簡單的協程的例子理解:
def simple_demo(): print('start') x = yield print('x:', x)sd = simple_demo()next(sd)sd.send(10)--------------------------->>> start>>> x: 10>>> Traceback (most recent call last):>>> File 'D:/python_projects/untitled3/xiecheng1.py', line 9, >>> in <module>>>> sd.send(10)>>> StopIteration
對上述例子的分析:
yield 的右邊沒有表達式,所以這里默認產出的值是None剛開始先調用了next(...)是因為這個時候生成器還沒有啟動,沒有停在yield那里,這個時候也是無法通過send發送數據。所以當我們通過next(...)激活協程后,程序就會運行到x = yield,這里有個問題我們需要注意,x = yield這個表達式的計算過程是先計算等號右邊的內容,然后在進行賦值,所以當激活生成器后,程序會停在yield這里,但并沒有給x賦值。
當我們調用send方法后yield會收到這個值并賦值給x,而當程序運行到協程定義體的末尾時和用生成器的時候一樣會拋出StopIteration異常
如果協程沒有通過next(...)激活(同樣我們可以通過send(None)的方式激活),但是我們直接send,會提示如下錯誤:
def simple_demo(): print('start') x = yield print('x:', x)sd = simple_demo()# next(sd)sd.send(10)--------------------------->>> Traceback (most recent call last):>>> File 'D:/python_projects/untitled3/xiecheng1.py', line 9, >>> in <module>>>> sd.send(10)>>> TypeError: can’t send non-None value to a just-started generator
關于調用next(...)函數這一步通常稱為”預激(prime)“協程,即讓協程向前執行到第一個yield表達式,準備好作為活躍的協程使用
協程在運行過程中有四個狀態:
GEN_CREATE:等待開始執行 GEN_RUNNING:解釋器正在執行,這個狀態一般看不到 GEN_SUSPENDED:在yield表達式處暫停 GEN_CLOSED:執行結束通過下面例子來查看協程的狀態:
>>> from inspect import getgeneratorstate>>> def simple_demo(a): print('start: a = ', a) b = yield a print('b = ', b) c = yield a + b print('c = ', c) >>> sd = simple_demo(2)>>> print(getgeneratorstate(sd))GEN_CREATED>>> next(sd) # 預激協程,使它走到第一個yield處,因為第一個yield處有yield值a,所以返回a的值,然后在此yield處阻塞start: a = 22>>> print(getgeneratorstate(sd))GEN_SUSPENDED>>> sd.send(3) # 發送3,進入協程接著上一次阻塞的yield處執行,yield接收參數3賦值給b,到下一個yield處返回a+b的值,然后在此yield處再次阻塞,等待下次send值b = 35>>> sd.send(4) # 同上一次send過程,到此結束拋異常c = 4Traceback (most recent call last): File '<pyshell#8>', line 1, in <module> sd.send(4)StopIteration>>> print(getgeneratorstate(sd))GEN_CLOSED
可以通過注釋理解這個例子。
接著再通過一個計算平均值的例子來繼續理解:
>>> def averager():total = 0.0count = 0average = Nonewhile True:term = yield averagetotal += termcount += 1average = total/count>>> avg = averager()>>> next(avg)>>> avg.send(10)10.0>>> avg.send(30)20.0>>> avg.send(40)26.666666666666668
這里是一個死循環,只要不停send值給協程,可以一直計算下去。通過上面的幾個例子我們發現,我們如果想要開始使用協程的時候必須通過next(...)方式激活協程,如果不預激,這個協程就無法使用,如果哪天在代碼中遺忘了那么就出問題了,所以有一種預激協程的裝飾器,可以幫助我們干這件事。
2.2、預激協程的裝飾器下面是預激裝飾器的演示例子:
from functools import wrapsdef coroutine(func): @wraps(func) def primer(*args,**kwargs):gen = func(*args,**kwargs)next(gen)return gen return primer@coroutinedef averager(): total = 0.0 count = 0 average = None while True:term = yield averagetotal += termcount += 1average = total/countcoro_avg = averager()from inspect import getgeneratorstateprint(getgeneratorstate(coro_avg))print(coro_avg.send(10))print(coro_avg.send(30))print(coro_avg.send(5))--------------------------->>> GEN_SUSPENDED>>> 10.0>>> 20.0>>> 15.0
關于預激,在使用yield from句法調用協程的時候,會自動預激活,這樣其實與我們上面定義的coroutine裝飾器是不兼容的,在python3.4里面的asyncio.coroutine裝飾器不會預激協程,因此兼容yield from
2.3、終止協程和異常處理協程中未處理的異常會向上冒泡,傳給 next 函數或 send 方法的調用方(即觸發協程的對象)。
繼續使用上面averager的例子
>>> coro_avg = averager()>>> coro_avg.send(40)40.0>>> coro_avg.send(50)45.0>>> coro_avg.send(’spam’)Traceback (most recent call last):...TypeError: unsupported operand type(s) for +=: ’float’ and ’str’>>> coro_avg.send(60)Traceback (most recent call last):File '<stdin>', line 1, in <module>StopIteration
由于在協程內沒有處理異常,協程會終止。如果試圖重新激活協程,會拋出StopIteration 異常。
從 Python 2.5 開始,客戶代碼可以在生成器對象上調用兩個方法:throw 和 close,顯式地把異常發給協程。
1:generator.throw(exc_type[, exc_value[, traceback]])
使生成器在暫停的 yield 表達式處拋出指定的異常。如果生成器處理了拋出的異常,代碼會向前執行到下一個 yield 表達式,而產出的值會成為調用 generator.throw方法得到的返回值。如果生成器沒有處理拋出的異常,異常會向上冒泡,傳到調用方的上下文中。
2:generator.close()
使生成器在暫停的 yield 表達式處拋出 GeneratorExit 異常。如果生成器沒有處理這個異常,或者拋出了 StopIteration 異常(通常是指運行到結尾),調用方不會報錯。如果收到 GeneratorExit 異常,生成器一定不能產出值,否則解釋器會拋出RuntimeError 異常。生成器拋出的其他異常會向上冒泡,傳給調用方。
示例如下:
from inspect import getgeneratorstateclass DemoException(Exception): '''為這次演示定義的異常類型。''' pass def demo_exc_handling(): print(’-> coroutine started’) while True:try: x = yieldexcept DemoException: print(’*** DemoException handled. Continuing...’)else: print(’-> coroutine received: {!r}’.format(x)) raise RuntimeError(’This line should never run.’) >>> exc_coro = demo_exc_handling()>>> next(exc_coro)-> coroutine started>>> exc_coro.send(11)-> coroutine received: 11>>> exc_coro.send(22)-> coroutine received: 22>>> exc_coro.throw(DemoException)*** DemoException handled. Continuing...>>> getgeneratorstate(exc_coro)’GEN_SUSPENDED’>>> exc_coro.close()>>> getgeneratorstate(exc_coro)’GEN_CLOSED’2.4、讓協程返回值
在Python2中,生成器函數中的return不允許返回附帶返回值。在Python3中取消了這一限制,因而允許協程可以返回值:
from collections import namedtupleResult = namedtuple(’Result’, ’count average’)def averager(): total = 0.0 count = 0 average = None while True:term = yieldif term is None: breaktotal += termcount += 1average = total/count return Result(count, average) >>> coro_avg = averager()>>> next(coro_avg)>>> coro_avg.send(10)>>> coro_avg.send(30)>>> coro_avg.send(6.5)>>> coro_avg.send(None)Traceback (most recent call last):...StopIteration: Result(count=3, average=15.5)
發送 None 會終止循環,導致協程結束,返回結果。一如既往,生成器對象會拋出StopIteration 異常。異常對象的 value 屬性保存著返回的值。
注意,return 表達式的值會偷偷傳給調用方,賦值給 StopIteration 異常的一個屬性。這樣做有點不合常理,但是能保留生成器對象的常規行為——耗盡時拋出StopIteration 異常。如果需要接收返回值,可以這樣:
>>> try:... coro_avg.send(None)... except StopIteration as exc:... result = exc.value...>>> resultResult(count=3, average=15.5)
獲取協程的返回值要繞個圈子,可以使用Python3.3引入的yield from獲取返回值。yield from 結構會在內部自動捕獲 StopIteration 異常。這種處理方式與 for 循環處理 StopIteration 異常的方式一樣。對 yield from 結構來說,解釋器不僅會捕獲 StopIteration 異常,還會把value 屬性的值變成 yield from 表達式的值。
2.5、yield from的使用yield from 是 Python3.3 后新加的語言結構。在其他語言中,類似的結構使用 await 關鍵字,這個名稱好多了,因為它傳達了至關重要的一點:在生成器 gen 中使用 yield from subgen() 時,subgen 會獲得控制權,把產出的值傳給 gen 的調用方,即調用方可以直接控制 subgen。與此同時,gen 會阻塞,等待 subgen 終止。
yield from 可用于簡化 for 循環中的 yield 表達式。例如:
>>> def gen():... for c in ’AB’:... yield c... for i in range(1, 3):... yield i...>>> list(gen())[’A’, ’B’, 1, 2]
可以改為
>>> def gen():... yield from ’AB’... yield from range(1, 3)...>>> list(gen())[’A’, ’B’, 1, 2]
yield from x 表達式對 x 對象所做的第一件事是,調用 iter(x),從中獲取迭代器。因此,x 可以是任何可迭代的對象。
如果 yield from 結構唯一的作用是替代產出值的嵌套 for 循環,這個結構很有可能不會添加到 Python 語言中。
yield from 的主要功能是打開雙向通道,把最外層的調用方與最內層的子生成器連接起來,這樣二者可以直接發送和產出值,還可以直接傳入異常,而不用在位于中間的協程中添加大量處理異常的樣板代碼。有了這個結構,協程可以通過以前不可能的方式委托職責。
PEP 380 使用了一些yield from使用的專門術語:
委派生成器:包含 yield from 表達式的生成器函數; 子生成器:從 yield from 表達式中 部分獲取的生成器; 調用方:調用委派生成器的客戶端代碼;委派生成器在 yield from 表達式處暫停時,調用方可以直接把數據發給子生成器,子生成器再把產出的值發給調用方。子生成器返回之后,解釋器會拋出StopIteration 異常,并把返回值附加到異常對象上,此時委派生成器會恢復。
下面是一個求平均身高和體重的示例代碼:
from collections import namedtupleResult = namedtuple(’Result’, ’count average’)# 子生成器def averager(): total = 0.0 count = 0 average = None while True:# main 函數發送數據到這里 print('in averager, before yield')term = yieldif term is None: # 終止條件 breaktotal += termcount += 1average = total/count print('in averager, return result') return Result(count, average) # 返回的Result 會成為grouper函數中yield from表達式的值# 委派生成器def grouper(results, key): # 這個循環每次都會新建一個averager 實例,每個實例都是作為協程使用的生成器對象 while True:print('in grouper, before yield from averager, key is ', key)results[key] = yield from averager()print('in grouper, after yield from, key is ', key)# 調用方def main(data): results = {} for key, values in data.items():# group 是調用grouper函數得到的生成器對象group = grouper(results, key)print('ncreate group: ', group)next(group) #預激 group 協程。print('pre active group ok')for value in values: # 把各個value傳給grouper 傳入的值最終到達averager函數中; # grouper并不知道傳入的是什么,同時grouper實例在yield from處暫停 print('send to %r value %f now'%(group, value)) group.send(value)# 把None傳入groupper,傳入的值最終到達averager函數中,導致當前實例終止。然后繼續創建下一個實例。# 如果沒有group.send(None),那么averager子生成器永遠不會終止,委派生成器也永遠不會在此激活,也就不會為result[key]賦值print('send to %r none'%group)group.send(None) print('report result: ') report(results)# 輸出報告def report(results): for key, result in sorted(results.items()):group, unit = key.split(’;’)print(’{:2} {:5} averaging {:.2f}{}’.format(result.count, group, result.average, unit))data = { ’girls;kg’:[40, 41, 42, 43, 44, 54], ’girls;m’: [1.5, 1.6, 1.8, 1.5, 1.45, 1.6], ’boys;kg’:[50, 51, 62, 53, 54, 54], ’boys;m’: [1.6, 1.8, 1.8, 1.7, 1.55, 1.6],}if __name__ == ’__main__’: main(data)
grouper 發送的每個值都會經由 yield from 處理,通過管道傳給 averager 實例。grouper 會在 yield from 表達式處暫停,等待 averager 實例處理客戶端發來的值。averager 實例運行完畢后,返回的值綁定到 results[key] 上。while 循環會不斷創建 averager 實例,處理更多的值。
外層 for 循環重新迭代時會新建一個 grouper 實例,然后綁定到 group 變量上。前一個 grouper 實例(以及它創建的尚未終止的 averager 子生成器實例)被垃圾回收程序回收。
代碼結果如下:
create group: <generator object grouper at 0x7f34ce8458e0>
in grouper, before yield from averager, key is girls;kg
in averager, before yield
pre active group ok
send to <generator object grouper at 0x7f34ce8458e0> value 40.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 41.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 42.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 43.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 44.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 54.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> none
in averager, return result
in grouper, after yield from, key is girls;kg
in grouper, before yield from averager, key is girls;kg
in averager, before yield
create group: <generator object grouper at 0x7f34ce845678>
in grouper, before yield from averager, key is girls;m
in averager, before yield
pre active group ok
send to <generator object grouper at 0x7f34ce845678> value 1.500000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845678> value 1.600000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845678> value 1.800000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845678> value 1.500000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845678> value 1.450000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845678> value 1.600000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845678> none
in averager, return result
in grouper, after yield from, key is girls;m
in grouper, before yield from averager, key is girls;m
in averager, before yield
create group: <generator object grouper at 0x7f34ce845620>
in grouper, before yield from averager, key is boys;kg
in averager, before yield
pre active group ok
send to <generator object grouper at 0x7f34ce845620> value 50.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845620> value 51.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845620> value 62.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845620> value 53.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845620> value 54.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845620> value 54.000000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce845620> none
in averager, return result
in grouper, after yield from, key is boys;kg
in grouper, before yield from averager, key is boys;kg
in averager, before yield
create group: <generator object grouper at 0x7f34ce8458e0>
in grouper, before yield from averager, key is boys;m
in averager, before yield
pre active group ok
send to <generator object grouper at 0x7f34ce8458e0> value 1.600000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 1.800000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 1.800000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 1.700000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 1.550000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> value 1.600000 now
in averager, before yield
send to <generator object grouper at 0x7f34ce8458e0> none
in averager, return result
in grouper, after yield from, key is boys;m
in grouper, before yield from averager, key is boys;m
in averager, before yield
report result:
6 boys averaging 54.00kg
6 boys averaging 1.68m
6 girls averaging 44.00kg
6 girls averaging 1.58m
這個試驗想表明的關鍵一點是,如果子生成器不終止,委派生成器會在yield from 表達式處永遠暫停。如果是這樣,程序不會向前執行,因為 yield from(與 yield 一樣)把控制權轉交給客戶代碼(即,委派生成器的調用方)了。
2.6、yield from的意義把迭代器當作生成器使用,相當于把子生成器的定義體內聯在 yield from 表達式中。此外,子生成器可以執行 return 語句,返回一個值,而返回的值會成為 yield from 表達式的值。
PEP 380 在“Proposal”一節(https://www.python.org/dev/peps/pep-0380/#proposal)分六點說明了 yield from 的行為。這里幾乎原封不動地引述,不過把有歧義的“迭代器”一詞都換成了“子生成器”,還做了進一步說明。上面的示例闡明了下述四點:
子生成器產出的值都直接傳給委派生成器的調用方(即客戶端代碼);
使用 send() 方法發給委派生成器的值都直接傳給子生成器。如果發送的值是None,那么會調用子生成器的 next() 方法。如果發送的值不是 None,那么會調用子生成器的 send() 方法。如果子生成器拋出 StopIteration 異常,那么委派生成器恢復運行。任何其他異常都會向上冒泡,傳給委派生成器;
生成器退出時,生成器(或子生成器)中的 return expr 表達式會觸發StopIteration(expr) 異常拋出;
yield from 表達式的值是子生成器終止時傳給 StopIteration 異常的第一個參數。
yield from 的具體語義很難理解,尤其是處理異常的那兩點。在PEP 380 中闡述了 yield from 的語義。還使用偽代碼(使用 Python 句法)演示了 yield from 的行為。
若想研究那段偽代碼,最好將其簡化,只涵蓋 yield from 最基本且最常見的用法:yield from 出現在委派生成器中,客戶端代碼驅動著委派生成器,而委派生成器驅動著子生成器。為了簡化涉及到的邏輯,假設客戶端沒有在委派生成器上調用throw(...) 或 close() 方法。而且假設子生成器不會拋出異常,而是一直運行到終止,讓解釋器拋出 StopIteration 異常。上面示例中的腳本就做了這些簡化邏輯的假設。
下面的偽代碼,等效于委派生成器中的 RESULT = yield from EXPR 語句(這里針對的是最簡單的情況:不支持 .throw(...) 和 .close() 方法,而且只處理 StopIteration 異常):
_i = iter(EXPR) try: _y = next(_i)except StopIteration as _e: _r = _e.valueelse: while 1:_s = yield _y try:_y = _i.send(_s) except StopIteration as _e:_r = _e.valuebreakRESULT = _r
但是,現實情況要復雜一些,因為要處理客戶對 throw(...) 和 close() 方法的調用,而這兩個方法執行的操作必須傳入子生成器。此外,子生成器可能只是純粹的迭代器,不支持 throw(...) 和 close() 方法,因此 yield from 結構的邏輯必須處理這種情況。如果子生成器實現了這兩個方法,而在子生成器內部,這兩個方法都會觸發異常拋出,這種情況也必須由 yield from 機制處理。調用方可能會無緣無故地讓子生成器自己拋出異常,實現 yield from 結構時也必須處理這種情況。最后,為了優化,如果調用方調用 next(...) 函數或 .send(None) 方法,都要轉交職責,在子生成器上調用next(...) 函數;僅當調用方發送的值不是 None 時,才使用子生成器的 .send(...) 方法。
下面的偽代碼,是考慮了上述情況之后,語句:RESULT = yield from EXPR的等效代碼:
_i = iter(EXPR)try: _y = next(_i)except StopIteration as _e: _r = _e.valueelse: while 1:try: _s = yield _yexcept GeneratorExit as _e: try:_m = _i.close except AttributeError:pass else:_m() raise _eexcept BaseException as _e: _x = sys.exc_info() try:_m = _i.throw except AttributeError:raise _e else:try: _y = _m(*_x)except StopIteration as _e: _r = _e.value breakelse: try:if _s is None: _y = next(_i)else: _y = _i.send(_s) except StopIteration as _e:_r = _e.valuebreakRESULT = _r
上面的偽代碼中,會預激子生成器。這表明,用于自動預激的裝飾器與 yield from 結構不兼容。
三、greenlet的使用python中為實現協程封裝了一些非常好用的包,首先介紹greenlet的使用。
Greenlet是python的一個C擴展,旨在提供可自行調度的‘微線程’, 即協程。generator實現的協程在yield value時只能將value返回給調用者(caller)。 而在greenlet中,target.switch(value)可以切換到指定的協程(target), 然后yield value。greenlet用switch來表示協程的切換,從一個協程切換到另一個協程需要顯式指定。
以下例子:
from greenlet import greenletdef test1(): print(12) gr2.switch() print(34)def test2(): print(56) gr1.switch() print(78)gr1 = greenlet(test1)gr2 = greenlet(test2)gr1.switch()--------------------------->>> 12>>> 56>>> 34
當創建一個greenlet時,首先初始化一個空的棧, switch到這個棧的時候,會運行在greenlet構造時傳入的函數(首先在test1中打印 12), 如果在這個函數(test1)中switch到其他協程(到了test2 打印34),那么該協程會被掛起,等到切換回來(在test2中切換回來 打印34)。當這個協程對應函數執行完畢,那么這個協程就變成dead狀態。
對于greenlet,最常用的寫法是 x = gr.switch(y)。 這句話的意思是切換到gr,傳入參數y。當從其他協程(不一定是這個gr)切換回來的時候,將值付給x。
import greenletdef test1(x, y): z = gr2.switch(x+y) print ’test1 ’, zdef test2(u): print ’test2 ’, u gr1.switch(10)gr1 = greenlet.greenlet(test1)gr2 = greenlet.greenlet(test2)print gr1.switch('hello', ' world')--------------------------->>> ’test2 ’ ’hello world’>>> ’test1 ’ 10>>> None
上面的例子,第12行從main greenlet切換到了gr1,test1第3行切換到了gs2,然后gr1掛起,第8行從gr2切回gr1時,將值(10)返回值給了 z。
使用greenlet需要注意一下三點:
第一:greenlet創生之后,一定要結束,不能switch出去就不回來了,否則容易造成內存泄露 第二:python中每個線程都有自己的main greenlet及其對應的sub-greenlet ,不能線程之間的greenlet是不能相互切換的 第三:不能存在循環引用,這個是官方文檔明確說明四、gevent的使用gevent可以自動捕獲I/O耗時操作,來自動切換協程任務。
import geventdef f1(): for i in range(5):print(’run func: f1, index: %s ’ % i)gevent.sleep(1)def f2(): for i in range(5):print(’run func: f2, index: %s ’ % i)gevent.sleep(1)t1 = gevent.spawn(f1)t2 = gevent.spawn(f2)gevent.joinall([t1, t2])------------------------------>>> run func: f1, index: 0 >>> run func: f2, index: 0 >>> run func: f1, index: 1 >>> run func: f2, index: 1 >>> run func: f1, index: 2 >>> run func: f2, index: 2 >>> run func: f1, index: 3 >>> run func: f2, index: 3 >>> run func: f1, index: 4 >>> run func: f2, index: 4
由圖中可以看出,f1和f2是交叉打印信息的,因為在代碼執行的過程中,我們人為使用gevent.sleep(0)創建了一個阻塞,gevent在運行到這里時就會自動切換函數切換函數。也可以在執行的時候sleep更長時間,可以發現兩個函數基本是同時運行然后各自等待。
關于協程,首先要充分理解協程的實現原理,然后使用現有的輪子greenlet和gevent時才能更加得心應手!
以上就是深入理解python協程的詳細內容,更多關于python協程的資料請關注好吧啦網其它相關文章!
相關文章: