快捷導(dǎo)航

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

更新時(shí)間：2019年02月19日 14:16:30 作者：夢(mèng)醒人醉

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

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

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

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

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

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

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è)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

python多個(gè)模塊py文件的數(shù)據(jù)共享實(shí)例
今天小編就為大家分享一篇python多個(gè)模塊py文件的數(shù)據(jù)共享實(shí)例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
2019-01-01
Pycharm配置lua編譯環(huán)境過(guò)程圖解
這篇文章主要介紹了Pycharm配置lua編譯環(huán)境過(guò)程圖解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-11-11
CentOS系統(tǒng)上安裝Conda的詳細(xì)指南
Conda 是一個(gè)開源的包管理系統(tǒng)和環(huán)境管理系統(tǒng),廣泛應(yīng)用于數(shù)據(jù)科學(xué)和機(jī)器學(xué)習(xí)領(lǐng)域,本文將詳細(xì)介紹如何在 CentOS 系統(tǒng)上安裝 Conda吧
2025-03-03
拿來(lái)就用！Python批量合并PDF的示例代碼
這篇文章主要介紹了Python批量合并PDF的示例代碼，幫助大家更好的理解和學(xué)習(xí)Python，感興趣的朋友可以了解下
2020-08-08
淺談python3.6的tkinter運(yùn)行問(wèn)題
今天小編就為大家分享一篇淺談python3.6的tkinter運(yùn)行問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
2019-02-02
Python使用Pandas對(duì)比兩列數(shù)據(jù)取最大值的五種方法
本文主要介紹使用 Pandas 對(duì)比兩列數(shù)據(jù)取最大值的五種方法,包括使用 max 方法、apply 方法結(jié)合 lambda 函數(shù)、函數(shù)、clip 方法、where 方法結(jié)合條件賦值,并通過(guò)案例進(jìn)行詳細(xì)說(shuō)明,需要的朋友可以參考下
2025-02-02
解析Python的縮進(jìn)規(guī)則的使用
這篇文章主要介紹了解析Python的縮進(jìn)規(guī)則的使用，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
2019-01-01
python實(shí)現(xiàn)連續(xù)變量最優(yōu)分箱詳解--CART算法
今天小編就為大家分享一篇python實(shí)現(xiàn)連續(xù)變量最優(yōu)分箱詳解--CART算法，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
2019-11-11
淺談python擴(kuò)展包安裝失敗解決方案
Python包安裝失敗最主要原因是默認(rèn)安裝源為國(guó)外服務(wù)器,安裝速度慢,但是在使用python擴(kuò)展包安裝失敗,本文就來(lái)介紹一下,感興趣的可以了解一下
2023-09-09
使用Python的turtle模塊畫國(guó)旗
這篇文章主要為大家詳細(xì)介紹了用Python的turtle模塊畫國(guó)旗，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2019-09-09