python中的asyncio異步協(xié)程怎么實現(xiàn)

這篇“python中的asyncio異步協(xié)程怎么實現(xiàn)”文章的知識點大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“python中的asyncio異步協(xié)程怎么實現(xiàn)”文章吧。

一、定義協(xié)程

• asyncio 執(zhí)行的任務，稱為協(xié)程，但是Asyncio 并不能帶來真正的并行

• Python 的多線程因為 GIL（全局解釋器鎖）的存在，也不能帶來真正的并行

import asyncio
# 通過 async 定義一個協(xié)程
async def task():
print('這是一個協(xié)程')
# 判斷是否是一個協(xié)程，返回True
print(asyncio.iscoroutinefunction(task))

二、運行協(xié)程

import asyncio
# 通過 async 定義一個協(xié)程
async def task(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
print('協(xié)程結(jié)束')
# 協(xié)程運行
loop = asyncio.get_event_loop()
loop.run_until_complete(task(3))

三、協(xié)程回調(diào)

• 加入我們處理完協(xié)程任務后，需要告訴開發(fā)人員，這里程序結(jié)束了

• 就需要使用到協(xié)程回調(diào)

import asyncio
# 通過 async 定義一個協(xié)程
async def task(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
return '這里task結(jié)束了，其他的繼續(xù)吧'
def callback(future):
print(future.result())
future = asyncio.ensure_future(task(3))
future.add_done_callback(callback)
loop = asyncio.get_event_loop()
loop.run_until_complete(future)
# 結(jié)果如下：
# 請等待 3 秒
# 這里task結(jié)束了，其他的繼續(xù)吧

四、運行多個協(xié)程

• 常常同一個項目中有多個協(xié)程

• 需要借助 asyncio.gather 函數(shù)運行

import asyncio
# 通過 async 定義一個協(xié)程
async def task1(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
print('這里task1結(jié)束了')
# 通過 async 定義一個協(xié)程
async def task2(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
print('這里task2結(jié)束了')
# 運行方法一
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.gather(task1(1), task2(3)))
# 運行方法二
coros = [task1(1), task1(3)]
loop.run_until_complete(asyncio.gather(*coros))
# 結(jié)果如下：
# 請等待 1 秒
# 請等待 3 秒
# 這里task1結(jié)束了
# 這里task2結(jié)束了

五、run_forever

• 通過run_until_complete 運行協(xié)程，協(xié)程運行完，程序也就結(jié)束退出了

• 使用run_forever 運行，程序并不會退出，除非調(diào)用 loop.stop()

import asyncio
# 通過 async 定義一個協(xié)程
async def task(s):
await asyncio.sleep(s)
# 程序并未退出結(jié)束
loop = asyncio.get_event_loop()
asyncio.ensure_future(task(3))
loop.run_forever()

• 如果想讓其退出，需要調(diào)用 loop.stop()

• 我們可以在協(xié)程中調(diào)用

import asyncio
# 通過 async 定義一個協(xié)程
async def task(loop, s):
await asyncio.sleep(s)
# 關(guān)閉run_forever
loop.close()
loop = asyncio.get_event_loop()
asyncio.ensure_future(task(loop, 3))
loop.run_forever()

六、多協(xié)程中關(guān)閉run_forever

• 單個協(xié)程中可以通過在協(xié)程中關(guān)閉，但是如果是兩個以上的協(xié)程的時候

• 如果有一個協(xié)程先做完了就stop了，將會導致其他的協(xié)程也會異常退出，這肯定是不允許的

• 所以我們可以在回調(diào)函數(shù)中進行關(guān)閉

import asyncio, functools
async def task(x):
await asyncio.sleep(x)
print('這是協(xié)程任務')
def callback(loop):
loop.stop()
loop = asyncio.get_event_loop()
future = asyncio.gather(task(1), task(3))
future.add_done_callback(functools.partial(callback, loop))
loop.run_forever()

以上就是關(guān)于“python中的asyncio異步協(xié)程怎么實現(xiàn)”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對大家有幫助，若想了解更多相關(guān)的知識內(nèi)容，請關(guān)注億速云行業(yè)資訊頻道。