快捷導(dǎo)航

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

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

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

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

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

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

運行結(jié)果：

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

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)運行在一個線程中，防止阻塞當(dāng)前主線程
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)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

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