python協(xié)程之動態(tài)添加任務(wù)的方法
python協(xié)程只能運行在事件循環(huán)中,但是一旦事件循環(huán)運行,又會阻塞當前任務(wù)。所以只能在當前進程中再開一個線程,這個線程的主要任務(wù)是運行事件循環(huán),就是event_loop,因為他是一個無限循環(huán),會阻塞當前線程。
放一個自己寫的demo,注釋寫的很詳細。
另外還有一點需要注意,一個事件循環(huán)中不能運行另外一個事件循環(huán)。
運行結(jié)果:

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

