您好,登錄后才能下訂單哦!
這篇文章主要講解了“Python協(xié)程怎么實(shí)現(xiàn)”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來(lái)研究和學(xué)習(xí)“Python協(xié)程怎么實(shí)現(xiàn)”吧!
協(xié)程不是計(jì)算機(jī)提供的,計(jì)算機(jī)只提供:進(jìn)程、線程。協(xié)程時(shí)人工創(chuàng)造的一種用戶態(tài)切換的微進(jìn)程,使用一個(gè)線程去來(lái)回切換多個(gè)進(jìn)程
實(shí)現(xiàn)協(xié)程的幾種方法
greenlet:早期模塊
yield關(guān)鍵字:可以保存代碼,保存狀態(tài)
asyncio裝飾器(3.4)
async、await關(guān)鍵字(3.5)【推薦】
pip install greenlet from greenlet import greenlet def fun1(): gre2.switch()#切換到fun2 pass def fun2(): gre1.switch()#切換到fun1 pass gre1 = greenlet(func1) gre2 = greenlet(func2) gre1.switch()#先去執(zhí)行fun1
def func1(): yield 1 yield from func2() yield 2 def func2(): yield 3 yield 4 f1 = func1() for item in f1: print(item,end=" ") #打印結(jié)果 1 3 4 2
再python3.4版本之后才可以用(不用安裝,在標(biāo)準(zhǔn)庫(kù)中)
import asyncio #使用該裝飾器裝飾后,該函數(shù)就是一個(gè)協(xié)程函數(shù) @asyncio.coroutine def func1(): print(1) #遇到IO操作時(shí),會(huì)自動(dòng)切換到taks中的其他任務(wù)函數(shù) yield from asyncio.sleep(2) print(2) @asyncio.coroutine def func2(): print(3) yield from asyncio.sleep(2) print(4) #將兩個(gè)協(xié)程函數(shù)封裝成一個(gè)tasks列表 tasks = [ asyncio.ensure_future(func1()), asyncio.ensure_future(func2()) ] # loop = asyncio.get_event_loop() loop.run_until_complete(func1())
import asyncio #使用該裝飾器裝飾后,該函數(shù)就是一個(gè)協(xié)程函數(shù) async def func1(): print(1) #遇到IO操作時(shí),會(huì)自動(dòng)切換到tasks中的其他任務(wù)函數(shù) await asyncio.sleep(2) print(2) async def func2(): print(3) await asyncio.sleep(2) print(4) #將兩個(gè)協(xié)程函數(shù)封裝成一個(gè)tasks列表 tasks = [ asyncio.ensure_future(func1()), asyncio.ensure_future(func2()) ] loop = asyncio.get_event_loop() loop.run_until_complete(tasks)
在線程中如果遇到IO等待時(shí)間,線程不會(huì)傻等著,會(huì)利用空閑的時(shí)間去做其他事情,也就是進(jìn)程異步執(zhí)行。
#協(xié)程請(qǐng)求資源使用第三方庫(kù)aiohttp import aiohttp
理解成一個(gè)死循環(huán),去檢測(cè)并執(zhí)行某些代碼
#偽代碼 任務(wù)列表 = [task1,task2...] while True: for 就緒任務(wù) in 可執(zhí)行任務(wù)列表: 執(zhí)行 for 已完成任務(wù) in 已完成任務(wù)列表: 從任務(wù)列表中刪除 import asyncio #生成一個(gè)書(shū)簡(jiǎn)循環(huán) loop = asyncio.get_event_loop() #將任務(wù)放到任務(wù)列表中 loop.run_until_complete(任務(wù))
協(xié)程函數(shù),
定義函數(shù)的時(shí)候,用async def 函數(shù)名
協(xié)程對(duì)象:執(zhí)行協(xié)程函數(shù)的時(shí)候得到一個(gè)協(xié)程對(duì)象
async def func(): pass result = func()
注意:執(zhí)行協(xié)程函數(shù)時(shí)得到的協(xié)程對(duì)象,函數(shù)內(nèi)部代碼不會(huì)執(zhí)行
import asyncio async def func(): print("哈嘍") f = func()#協(xié)程對(duì)象 loop = asyncio.get_event_loop()#創(chuàng)建循環(huán)對(duì)象 loop.run_until_complete(f)#通過(guò)循環(huán)對(duì)象執(zhí)行協(xié)程對(duì)象 #python3.7可以直接 asyncio.run(f)
await + 可等待的對(duì)象 {協(xié)程對(duì)象,F(xiàn)uture對(duì)象,Task對(duì)象} (類似于I O 等待)
import asyncio async def func(): print("哈嘍") re = await asyncio.sleep(2) print(re) asyncio.run(func())
await就是等待對(duì)象的值得到結(jié)果后再繼續(xù)向下執(zhí)行
import asyncio async def other(): print("start") await asyncio.sleep(2) print("end") return 1 async def fun(): print("執(zhí)行協(xié)程函數(shù)內(nèi)部代碼") #遇到IO操作時(shí)會(huì)掛起當(dāng)前協(xié)程任務(wù),等IO操作完成后再繼續(xù)往下執(zhí)行,當(dāng)前協(xié)程掛起時(shí),時(shí)間循環(huán)對(duì)象可以執(zhí)行其他協(xié)程任務(wù) re = await other() print("IO請(qǐng)求結(jié)束,結(jié)果為:",re) asyncio.run(func())
執(zhí)行結(jié)果
執(zhí)行協(xié)程函數(shù)內(nèi)部代碼
start
end
IO請(qǐng)求結(jié)束,結(jié)果為: 1
感謝各位的閱讀,以上就是“Python協(xié)程怎么實(shí)現(xiàn)”的內(nèi)容了,經(jīng)過(guò)本文的學(xué)習(xí)后,相信大家對(duì)Python協(xié)程怎么實(shí)現(xiàn)這一問(wèn)題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云,小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。