目標(biāo)

協(xié)程中斷, 并交出控制權(quán)

想說的話

本系列主要側(cè)重理解, 而不是編程初期的知識學(xué)習(xí), 當(dāng)我想要理解協(xié)程中斷的時(shí)候, 搜索了很多文章, 都指向需要使用asyncio.get_event_loop(), 但這是一個(gè)封裝了很多邏輯的代碼, 為了直觀理解, 編寫了如下例子

例子說明

每一行程序都是按順序一步一步執(zhí)行的，如果有程序不是按順序執(zhí)行，表示曾經(jīng)交出了控制權(quán)，以下的例子，本來應(yīng)該應(yīng)該順序輸出1,2，但是因?yàn)閞eq1交出了控制權(quán)，所以，輸出了2,1


import time
from collections import deque

_delay = deque()


def sleep0():
yield
return None


def req1():
yield
b = yield from sleep0()
return 1


def req2():
yield
return 2


f1 = req1()
f1.send(None)
try:
result = f1.send(None)
except StopIteration as e:
print(f'正常打印 {e.value}')
pass
else:
_delay.append((f1, 1+time.time()))

f = req2()
f.send(None)
try:
f.send(None)
except StopIteration as e:
print(f'正常打印 {e.value}')
pass

for i, v in _delay:
start = v
while True:
end = time.time()
if start < end:
try:
result = i.send(None)
except StopIteration as e:
print(f'延遲打印 {e.value}')
pass
break
pass

'''
結(jié)果:
正常打印 2
延遲打印 1
'''


審核編輯：劉清