快捷導(dǎo)航

python協(xié)程之動態(tài)添加任務(wù)的方法

更新時間：2019年02月19日 14:16:30 作者：夢醒人醉

今天小編就為大家分享一篇python協(xié)程之動態(tài)添加任務(wù)的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧

python協(xié)程只能運(yùn)行在事件循環(huán)中，但是一旦事件循環(huán)運(yùn)行，又會阻塞當(dāng)前任務(wù)。所以只能在當(dāng)前進(jìn)程中再開一個線程，這個線程的主要任務(wù)是運(yùn)行事件循環(huán)，就是event_loop,因?yàn)樗且粋€無限循環(huán)，會阻塞當(dāng)前線程。

放一個自己寫的demo，注釋寫的很詳細(xì)。

另外還有一點(diǎn)需要注意，一個事件循環(huán)中不能運(yùn)行另外一個事件循環(huán)。

運(yùn)行結(jié)果：

python協(xié)程之動態(tài)添加任務(wù)

import asyncio
from threading import Thread
 
 
async def production_task():
  i = 0
  while True:
    # 將consumption這個協(xié)程每秒注冊一個到運(yùn)行在線程中的循環(huán)，thread_loop每秒會獲得一個一直打印i的無限循環(huán)任務(wù)
    asyncio.run_coroutine_threadsafe(consumption(i),
                     thread_loop) # 注意：run_coroutine_threadsafe 這個方法只能用在運(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)來運(yùn)行
  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)運(yùn)行在一個線程中，防止阻塞當(dāng)前主線程
run_loop_thread.start() # 運(yùn)行線程，同時協(xié)程事件循環(huán)也會運(yùn)行
 
advocate_loop = asyncio.get_event_loop() # 將生產(chǎn)任務(wù)的協(xié)程注冊到這個循環(huán)中
advocate_loop.run_until_complete(production_task()) # 運(yùn)行次循環(huán)

以上這篇python協(xié)程之動態(tài)添加任務(wù)的方法就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

python?解決?pip?時報錯?no?suchoption:?--bulid-dir?的解決辦法(最新
在使用PyCharm虛擬環(huán)境pip時，有時會遇到錯誤提示“no?such?option:?--build-dir”，這可能是由于pip版本不兼容或其他原因?qū)е碌模疚膶⒃敿?xì)講解如何解決這個問題，感興趣的朋友跟隨小編一起看看吧
2023-05-05
python數(shù)據(jù)結(jié)構(gòu)鏈表之單向鏈表(實(shí)例講解)
下面小編就為大家?guī)硪黄猵ython數(shù)據(jù)結(jié)構(gòu)鏈表之單向鏈表(實(shí)例講解)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-07-07
Python字典一個key對應(yīng)多個value幾種實(shí)現(xiàn)方式
python中字典的健和值是一一對應(yīng)的,如果對字典進(jìn)行添加操作時如果健的名字相同,則當(dāng)前健對應(yīng)的值就會被覆蓋,有時候我們想要一個健對應(yīng)多個值的場景,這篇文章主要給大家介紹了關(guān)于Python字典一個key對應(yīng)多個value幾種實(shí)現(xiàn)方式的相關(guān)資料,需要的朋友可以參考下
2023-10-10
python 音頻和視頻合并自動裁剪
本文主要介紹了python 音頻和視頻合并自動裁剪,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2024-06-06
基于PyQt5實(shí)現(xiàn)SqlServer數(shù)據(jù)庫表導(dǎo)出Excel表格小工具
這篇文章主要為大家詳細(xì)介紹了PyQt5的應(yīng)用案例之實(shí)現(xiàn)SqlServer數(shù)據(jù)庫表導(dǎo)出Excel表格小工具,文中的示例代碼講解詳細(xì),需要的小伙伴可以參考一下
2023-12-12
詳解python中的defaultdict?默認(rèn)值
這篇文章主要介紹了defaultdict?默認(rèn)值,defaultdict是python內(nèi)建dict類的一個字類，功能與dict相同，但它帶有一個默認(rèn)的值，若key值不存在時返回一個默認(rèn)的值，本文通過實(shí)例代碼給大家介紹的非常詳細(xì)，需要的朋友可以參考下
2023-04-04
OpenCV立體圖像深度圖Depth Map基礎(chǔ)
這篇文章主要為大家介紹了OpenCV立體圖像深度圖Depth Map基礎(chǔ)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2023-05-05
python抓取網(wǎng)站的圖片并下載到本地的方法
今天小編就為大家分享一篇python抓取網(wǎng)站的圖片并下載到本地的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2018-05-05
python Django 創(chuàng)建應(yīng)用過程圖示詳解
這篇文章主要介紹了python Django 創(chuàng)建應(yīng)用過程圖示詳解,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
2019-07-07
python3.x提取中文的正則表達(dá)式示例代碼
這篇文章主要介紹了python3.x中提取中文的正則表達(dá)式的書寫,需要的朋友可以參考下
2019-07-07