python3 使用 asyncio 代替線程

bergwhite 發(fā)布于2019-07-30 15:35 / 3705人閱讀

摘要：提供了協(xié)程專用的關(guān)鍵字還提供了庫(kù)來(lái)進(jìn)行異步非阻塞的操作異步非阻塞的操作沒(méi)有老師檢查我也不知道自己算不算完全懂了就不做無(wú)用功嘗試說(shuō)得通俗易懂了想要從原理開(kāi)始理解的話推薦的文檔我為何使用來(lái)代替?zhèn)鹘y(tǒng)線程進(jìn)行操作由于時(shí)間主要耗費(fèi)在操作上其他操作并發(fā)

python3提供了協(xié)程專用的關(guān)鍵字async await, 還提供了asyncio庫(kù), 來(lái)進(jìn)行異步非阻塞的io操作

異步非阻塞的io操作?

沒(méi)有老師檢查我也不知道自己算不算完全懂了, 就不做無(wú)用功嘗試說(shuō)得通俗易懂了.
想要從原理開(kāi)始理解的話, 推薦tornado的文檔

我為何使用asyncio來(lái)代替?zhèn)鹘y(tǒng)線程進(jìn)行io操作?

由于時(shí)間主要耗費(fèi)在io操作上, 其他操作并發(fā)需求不大.

不用規(guī)定并行多少, 比較方便穩(wěn)定.

熟悉tornado工作原理

舉例

并行訪問(wèn)某網(wǎng)頁(yè)十次

import asyncio
import requests
loop = asyncio.get_event_loop()
async def t():                                                    
    get = lambda:requests.get("http://baidu.com")
    temp = await loop.run_in_executor(None, get)
    print(temp)   
loop.run_until_complete(asyncio.gather(*[t() for i in range(10)]))

上面這幾行代碼就可以完成這些操作了.

loop = asyncio.get_event_loop() 協(xié)程本身并不具備并行能力, 但是有了這個(gè)事件loop就可以進(jìn)行并行io請(qǐng)求

get = lambda:requests.get("http://baidu.com")
temp = await loop.run_in_executor(None, get)

一般函數(shù)是無(wú)法被await修飾的, 必須用api封裝一下(感覺(jué)很像threading), 我之所以再封裝一次get, 是因?yàn)?b>run_in_executor傳參數(shù)比較坑, 不支持**kwargs

loop.run_until_complete(asyncio.gather(*[t() for i in range(10)]))

run_until_complete這個(gè)api是指運(yùn)行內(nèi)容物直到結(jié)束(api如其名), gather是把任務(wù)組合到一起, 如果*的部分有迷惑的話, 你寫(xiě)asycio.gather(t(),t(), t()...)也是可以的.

おわり.