快捷導(dǎo)航

Python asyncio異步編程常見問題小結(jié)

更新時間：2023年01月18日 09:18:56 作者：永遠是少年啊

本文主要介紹了Python asyncio異步編程常見問題小結(jié)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

一、asyncio編程簡單示例

首先，我們來看一段簡單的Python asyncio異步編程代碼，相關(guān)代碼如下所示：

import asyncio

async def fun():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return 3

async def main():
    task_list=[
        asyncio.create_task(fun()),
        asyncio.create_task(fun())
    ]
	done,pending=await asyncio.wait(task_list)
    print(done)
asyncio.run(main())

在上述代碼中，我們使用了Task列表，將兩個fun()協(xié)程函數(shù)生成的Task對象添加到task列表中，最終實現(xiàn)了這兩個函數(shù)異步執(zhí)行。上述代碼執(zhí)行結(jié)果如下所示：

二、asyncio編程常見問題

下面，我們想要簡單的修改一下上述代碼，我們把main()函數(shù)刪除，嘗試直接生成協(xié)程對象列表，結(jié)果如下所示：

import asyncio

async def fun():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return 3

task_list=[
    asyncio.create_task(fun()),
    asyncio.create_task(fun())
]

done,pending=asyncio.run(asyncio.wait(task_list))
print(done)

上述代碼執(zhí)行結(jié)果如下所示：

三、報錯原因及解決方案

從上圖中可以看出，上述代碼執(zhí)行報錯，錯誤提示為：RuntimeError：no running event loop。
其實，之所以出現(xiàn)上述報錯，直接原因在于當(dāng)前沒有事件循環(huán)。當(dāng)我們使用asyncio模塊來實現(xiàn)異步編程時，asyncio模塊的優(yōu)點在于省略了我們創(chuàng)建事件循環(huán)的過程，但是這并不意味著asyncio異步編程不需要事件循環(huán)。事實上，在第一段代碼中，代碼：

asyncio.run(main())

在實際上創(chuàng)建了這個事件循環(huán)，但是asyncio模塊屏蔽了這一細節(jié)。而正是因為已經(jīng)存在了事件循環(huán)，因此我們才可以執(zhí)行命令：

done,pending=await asyncio.wait(task_list)

但是在上述代碼中，我們沒有創(chuàng)建事件循環(huán)，而是直接將該代碼放到主程序中執(zhí)行，因此上述代碼會出現(xiàn)報錯。
針對上述代碼，我們可以簡單修改為以下內(nèi)容：

import asyncio

async def fun():
    print(1)
    await asyncio.sleep(2)
    print(2)
    return 3

task_list=[
    fun(),
    fun()
]

done,pending=asyncio.run(asyncio.wait(task_list))
print(done)

在上述代碼中，我們的Task列表中存放的是協(xié)程對象，而不是Task對象，這樣，我們在執(zhí)行asyncio.wait時會自動創(chuàng)建一個事件循環(huán)，并且把協(xié)程對象加入到事件循環(huán)中。因此上述代碼也就不會報錯了。執(zhí)行結(jié)果如下所示：