https://blog.csdn.net/qq_29349715/article/details/79730786

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協程之動態添加任務