Python異步編程之協(xié)程任務(wù)的調(diào)度操作實(shí)例分析
本文實(shí)例講述了Python異步編程之協(xié)程任務(wù)的調(diào)度操作。分享給大家供大家參考,具體如下:
我們知道協(xié)程是異步進(jìn)行的,碰到IO阻塞型操作時(shí)需要調(diào)度其他任務(wù),那么這個(gè)調(diào)度規(guī)則或者是算法是怎樣的呢?現(xiàn)在有以下幾個(gè)疑問:
1、多個(gè)任務(wù)準(zhǔn)備好,需要運(yùn)行時(shí),優(yōu)先執(zhí)行哪一個(gè)?
2、一個(gè)任務(wù)運(yùn)行時(shí),如果別的任務(wù)準(zhǔn)備好了,是否需要中斷當(dāng)前任務(wù)呢?
在網(wǎng)上找了很多資料,也無法找到相關(guān)的資料,于是編寫了幾個(gè)簡單的程序,查看任務(wù)的執(zhí)行過程。
根據(jù)Python的asyncio我們可以編寫一個(gè)簡單的程序:
import asyncio async def a(x): while x>0: print('a:',x) await asyncio.sleep(0.5) x -= 1 async def b(x): while x>0: print('b:',x) await asyncio.sleep(1.8) x -= 1 async def c(x): while x>0: print('c:',x) await asyncio.sleep(1.5) x -= 1 loop = asyncio.get_event_loop() tasks = [a(2),b(2),c(2)] loop.run_until_complete(asyncio.wait(tasks)) loop.close()
我們創(chuàng)建一個(gè)loop事件,把a(bǔ),b,c3個(gè)函數(shù)加入到任務(wù)中,用asyncio.sleep(1)來切換運(yùn)行其他程序。運(yùn)行結(jié)果如下:
b: 2
c: 2
a: 2
a: 1
c: 1
b: 1
這里一直有一個(gè)疑問,開始運(yùn)行任務(wù)時(shí),3個(gè)任務(wù)同時(shí)準(zhǔn)備好,為什么執(zhí)行順序是b,a,c。
我們分析一下函數(shù)的執(zhí)行過程,先執(zhí)行b,然后阻塞,執(zhí)行c,阻塞,再執(zhí)行a,阻塞。函數(shù)調(diào)用過程是b->c->a,0.5s過后a完成,1.5s過后c完成,1.8s過后b完成。
修改睡眠時(shí)間,我們可以測試出很多情況,最后得出了任務(wù)調(diào)度的規(guī)則,可能有一些地方總結(jié)的不對,歡迎大家來指正。
1、初始化,asyncio把需要執(zhí)行的任務(wù)加入到任務(wù)隊(duì)列中。
2、從隊(duì)首拿出一個(gè)任務(wù)來運(yùn)行,如果任務(wù)被阻塞,則拿另一個(gè)任務(wù)隊(duì)列,在任務(wù)切換是需要保存每個(gè)任務(wù)的工作環(huán)境。
3、把IO的完成,定時(shí)時(shí)間到的時(shí)間加入到事件隊(duì)列,從隊(duì)首中拿出事件去喚醒相應(yīng)的任務(wù)。
好像看起來很簡單,又有點(diǎn)像操作系統(tǒng),又有點(diǎn)像中斷,但是操作系統(tǒng)是感知不到它的存在,更沒有調(diào)用中斷了。這里我們要注意,加入有一個(gè)任務(wù)正在運(yùn)行,同時(shí)有一個(gè)事件發(fā)生,asyncio是不會(huì)中斷當(dāng)前任務(wù)的,而是等這個(gè)任務(wù)碰到了阻塞才會(huì)處理這個(gè)事件,所以編程時(shí)需要把任務(wù)分的很細(xì),盡量不要讓任務(wù)執(zhí)行過長的時(shí)間。
更多關(guān)于Python相關(guān)內(nèi)容感興趣的讀者可查看本站專題:《Python進(jìn)程與線程操作技巧總結(jié)》、《Python數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Python函數(shù)使用技巧總結(jié)》、《Python字符串操作技巧匯總》、《Python入門與進(jìn)階經(jīng)典教程》、《Python+MySQL數(shù)據(jù)庫程序設(shè)計(jì)入門教程》及《Python常見數(shù)據(jù)庫操作技巧匯總》
希望本文所述對大家Python程序設(shè)計(jì)有所幫助。
相關(guān)文章
tf.nn.conv2d與tf.layers.conv2d的區(qū)別及說明
這篇文章主要介紹了tf.nn.conv2d與tf.layers.conv2d的區(qū)別及說明,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-02-02Pytorch?和?Tensorflow?v1?兼容的環(huán)境搭建方法
這篇文章主要介紹了搭建Pytorch?和?Tensorflow?v1?兼容的環(huán)境,本文是小編經(jīng)過多次實(shí)踐得到的環(huán)境配置教程,給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-11-11python如何使用雙線性插值計(jì)算網(wǎng)格內(nèi)數(shù)據(jù)
這篇文章主要介紹了python如何使用雙線性插值計(jì)算網(wǎng)格內(nèi)數(shù)據(jù)問題,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-08-08python中使用正則表達(dá)式的后向搜索肯定模式(推薦)
這篇文章主要介紹了python里使用正則表達(dá)式的后向搜索肯定模式,本文通過代碼介紹的非常詳細(xì),包括語法介紹,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友可以參考下2017-11-11總結(jié)分析Python的5個(gè)硬核函數(shù)
今天看到一篇很好的 Python 博文,結(jié)合自己的經(jīng)驗(yàn)總結(jié),分享給大家一篇關(guān)于eval, exec, compile, locals, globals這些函數(shù)的文章2021-11-11導(dǎo)入pytorch時(shí)libmkl_intel_lp64.so找不到問題解決
這篇文章主要為大家介紹了導(dǎo)入pytorch時(shí)libmkl_intel_lp64.so找不到問題解決示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06