python協(xié)程之動(dòng)態(tài)添加任務(wù)的方法
python協(xié)程只能運(yùn)行在事件循環(huán)中,但是一旦事件循環(huán)運(yùn)行,又會(huì)阻塞當(dāng)前任務(wù)。所以只能在當(dāng)前進(jìn)程中再開(kāi)一個(gè)線程,這個(gè)線程的主要任務(wù)是運(yùn)行事件循環(huán),就是event_loop,因?yàn)樗且粋€(gè)無(wú)限循環(huán),會(huì)阻塞當(dāng)前線程。
放一個(gè)自己寫(xiě)的demo,注釋寫(xiě)的很詳細(xì)。
另外還有一點(diǎn)需要注意,一個(gè)事件循環(huán)中不能運(yùn)行另外一個(gè)事件循環(huán)。
運(yùn)行結(jié)果:
import asyncio from threading import Thread async def production_task(): i = 0 while True: # 將consumption這個(gè)協(xié)程每秒注冊(cè)一個(gè)到運(yùn)行在線程中的循環(huán),thread_loop每秒會(huì)獲得一個(gè)一直打印i的無(wú)限循環(huán)任務(wù) asyncio.run_coroutine_threadsafe(consumption(i), thread_loop) # 注意:run_coroutine_threadsafe 這個(gè)方法只能用在運(yùn)行在線程中的循環(huán)事件使用 await asyncio.sleep(1) # 必須加await i += 1 async def consumption(i): while True: print("我是第{}任務(wù)".format(i)) await asyncio.sleep(1) def start_loop(loop): # 運(yùn)行事件循環(huán), loop以參數(shù)的形式傳遞進(jìn)來(lái)運(yùn)行 asyncio.set_event_loop(loop) loop.run_forever() thread_loop = asyncio.new_event_loop() # 獲取一個(gè)事件循環(huán) run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 將次事件循環(huán)運(yùn)行在一個(gè)線程中,防止阻塞當(dāng)前主線程 run_loop_thread.start() # 運(yùn)行線程,同時(shí)協(xié)程事件循環(huán)也會(huì)運(yùn)行 advocate_loop = asyncio.get_event_loop() # 將生產(chǎn)任務(wù)的協(xié)程注冊(cè)到這個(gè)循環(huán)中 advocate_loop.run_until_complete(production_task()) # 運(yùn)行次循環(huán)
以上這篇python協(xié)程之動(dòng)態(tài)添加任務(wù)的方法就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
- python已協(xié)程方式處理任務(wù)實(shí)現(xiàn)過(guò)程
- Python協(xié)程操作之gevent(yield阻塞,greenlet),協(xié)程實(shí)現(xiàn)多任務(wù)(有規(guī)律的交替協(xié)作執(zhí)行)用法詳解
- python多任務(wù)之協(xié)程的使用詳解
- python線程、進(jìn)程和協(xié)程詳解
- 深入淺析python中的多進(jìn)程、多線程、協(xié)程
- python并發(fā)編程之多進(jìn)程、多線程、異步和協(xié)程詳解
- python編程使用協(xié)程并發(fā)的優(yōu)缺點(diǎn)
- python協(xié)程用法實(shí)例分析
- python中的協(xié)程深入理解
- python任務(wù)調(diào)度實(shí)例分析
- Python異步編程之協(xié)程任務(wù)的調(diào)度操作實(shí)例分析
相關(guān)文章
python?解決?pip?時(shí)報(bào)錯(cuò)?no?suchoption:?--bulid-dir?的解決辦法(最新
在使用PyCharm虛擬環(huán)境pip時(shí),有時(shí)會(huì)遇到錯(cuò)誤提示“no?such?option:?--build-dir”,這可能是由于pip版本不兼容或其他原因?qū)е碌?,本文將詳?xì)講解如何解決這個(gè)問(wèn)題,感興趣的朋友跟隨小編一起看看吧2023-05-05python數(shù)據(jù)結(jié)構(gòu)鏈表之單向鏈表(實(shí)例講解)
下面小編就為大家?guī)?lái)一篇python數(shù)據(jù)結(jié)構(gòu)鏈表之單向鏈表(實(shí)例講解)。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-07-07Python字典一個(gè)key對(duì)應(yīng)多個(gè)value幾種實(shí)現(xiàn)方式
python中字典的健和值是一一對(duì)應(yīng)的,如果對(duì)字典進(jìn)行添加操作時(shí)如果健的名字相同,則當(dāng)前健對(duì)應(yīng)的值就會(huì)被覆蓋,有時(shí)候我們想要一個(gè)健對(duì)應(yīng)多個(gè)值的場(chǎng)景,這篇文章主要給大家介紹了關(guān)于Python字典一個(gè)key對(duì)應(yīng)多個(gè)value幾種實(shí)現(xiàn)方式的相關(guān)資料,需要的朋友可以參考下2023-10-10基于PyQt5實(shí)現(xiàn)SqlServer數(shù)據(jù)庫(kù)表導(dǎo)出Excel表格小工具
這篇文章主要為大家詳細(xì)介紹了PyQt5的應(yīng)用案例之實(shí)現(xiàn)SqlServer數(shù)據(jù)庫(kù)表導(dǎo)出Excel表格小工具,文中的示例代碼講解詳細(xì),需要的小伙伴可以參考一下2023-12-12詳解python中的defaultdict?默認(rèn)值
這篇文章主要介紹了defaultdict?默認(rèn)值,defaultdict是python內(nèi)建dict類(lèi)的一個(gè)字類(lèi),功能與dict相同,但它帶有一個(gè)默認(rèn)的值,若key值不存在時(shí)返回一個(gè)默認(rèn)的值,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),需要的朋友可以參考下2023-04-04python Django 創(chuàng)建應(yīng)用過(guò)程圖示詳解
這篇文章主要介紹了python Django 創(chuàng)建應(yīng)用過(guò)程圖示詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-07-07