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())  # 執行次迴圈