前言

書(shū)接上文，本文造第二個(gè)輪子，也是asyncio包里面非常常用的一個(gè)函數(shù)run

讓客戶滿意是我們工作的目標(biāo)，不斷超越客戶的期望值來(lái)自于我們對(duì)這個(gè)行業(yè)的熱愛(ài)。我們立志把好的技術(shù)通過(guò)有效、簡(jiǎn)單的方式提供給客戶，將通過(guò)不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長(zhǎng)期合作伙伴，公司提供的服務(wù)項(xiàng)目有：主機(jī)域名、虛擬主機(jī)、營(yíng)銷軟件、網(wǎng)站建設(shè)、安化網(wǎng)站維護(hù)、網(wǎng)站推廣。

一、知識(shí)準(zhǔn)備

● 相對(duì)于run_until_complete，改動(dòng)并不大，就是將入口函數(shù)重新封裝了一下，基礎(chǔ)知識(shí)主要還是run_until_complete的內(nèi)容
● asyncio.run是Python3.7之后新增的入口函數(shù)

二、環(huán)境準(zhǔn)備

三、run的實(shí)現(xiàn)

先來(lái)看下官方asyncio的使用方法：

|># more main.py
import asyncio
async def hello():
    print('enter hello ...')
    return 'world'

if __name__ == "__main__":
    rst = asyncio.run(hello())
    print(rst)
    
|># python3 main.py
enter hello ...
return world ...

來(lái)看下造的輪子的使用方式：

? more main.py
from wilsonasyncio import run

async def hello():
    print('enter hello ...')
    return 'return world ...'

if __name__ == "__main__":
    ret = run(hello())
    print(ret)

    
? python3 main.py
enter hello ...
return world ...

自己造的輪子也很好的運(yùn)行了，下面我們來(lái)看下輪子的代碼

四、代碼解析

輪子代碼

1）代碼組成

|># tree
.
├── eventloops.py 
├── futures.py
├── main.py
├── tasks.py
├── wilsonasyncio.py

2）代碼概覽：

eventloops.py

tasks.py

futures.py

3）執(zhí)行過(guò)程

3.1）入口函數(shù)

main.py

async def hello():
    print('enter hello ...')
    return 'return world ...'

if __name__ == "__main__":
    ret = run(hello())
    print(ret)

• ret = run(hello())直接調(diào)用run，參數(shù)是用戶函數(shù)hello()，我們看下run的源碼

def run(main):
    loop = get_event_loop()
    return loop.run_until_complete(main)

• loop = get_event_loop()獲取事件循環(huán)
• return loop.run_until_complete(main)調(diào)用run_until_complete

3.2）事件循環(huán)啟動(dòng)

    def run_until_complete(self, future):
        future = tasks.ensure_future(future, loop=self)
        future.add_done_callback(_complete_eventloop, future)
        self.run_forever()
        return future.result()

• 與之前略有不同，future = tasks.ensure_future(future, loop=self)，調(diào)用了tasks.ensure_future

def ensure_future(coro_or_future, *, loop=None):
    if isinstance(coro_or_future, Future):
        return coro_or_future
    else:
        return loop.create_task(coro_or_future)

• 如果傳入的對(duì)象是一個(gè)普通函數(shù)，那就封裝成一個(gè)task；如果已經(jīng)是一個(gè)future對(duì)象，那就直接返回。這一步的目的主要是確保傳入的對(duì)象，是一個(gè)Future類型

剩下的部分已經(jīng)沒(méi)有什么新鮮的了，和run_until_complete一樣，我們直接跳過(guò)...

3.7）執(zhí)行結(jié)果

? python3 main.py
enter hello ...
return world ...

五、流程總結(jié)

六、小結(jié)

● run與run_until_complete大同小異，只不過(guò)入口函數(shù)做了一些調(diào)整，使得用戶調(diào)用更加的便利
● 本文中的代碼，參考了python 3.7.7中asyncio的源代碼，裁剪而來(lái)
● 本文中代碼：代碼

至此，本文結(jié)束
在下才疏學(xué)淺，有撒湯漏水的，請(qǐng)各位不吝賜教...
更多文章，請(qǐng)關(guān)注我：wilson.chai