溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
python協程只能運行在事件循環中，但是一旦事件循環運行，又會阻塞當前任務。所以只能在當前進程中再開一個線程，這個線程的主要任務是運行事件循環，就是event_loop,因為他是一個無限循環，會阻塞當前線程。
放一個自己寫的demo，注釋寫的很詳細。
另外還有一點需要注意，一個事件循環中不能運行另外一個事件循環。
運行結果：
import asyncio
from threading import Thread
async def production_task():
i = 0
while True:
# 將consumption這個協程每秒注冊一個到運行在線程中的循環，thread_loop每秒會獲得一個一直打印i的無限循環任務
asyncio.run_coroutine_threadsafe(consumption(i),
thread_loop) # 注意：run_coroutine_threadsafe 這個方法只能用在運行在線程中的循環事件使用
await asyncio.sleep(1) # 必須加await
i += 1
async def consumption(i):
while True:
print("我是第{}任務".format(i))
await asyncio.sleep(1)
def start_loop(loop):
# 運行事件循環， loop以參數的形式傳遞進來運行
asyncio.set_event_loop(loop)
loop.run_forever()
thread_loop = asyncio.new_event_loop() # 獲取一個事件循環
run_loop_thread = Thread(target=start_loop, args=(thread_loop,)) # 將次事件循環運行在一個線程中，防止阻塞當前主線程
run_loop_thread.start() # 運行線程，同時協程事件循環也會運行
advocate_loop = asyncio.get_event_loop() # 將生產任務的協程注冊到這個循環中
advocate_loop.run_until_complete(production_task()) # 運行次循環
以上這篇python協程之動態添加任務的方法就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
