python中的asyncio異步協程怎么實現

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

一、定義協程

• asyncio 執行的任務，稱為協程，但是Asyncio 并不能帶來真正的并行

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

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

二、運行協程

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

三、協程回調

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

• 就需要使用到協程回調

import asyncio
# 通過 async 定義一個協程
async def task(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
return '這里task結束了，其他的繼續吧'
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)
# 結果如下：
# 請等待 3 秒
# 這里task結束了，其他的繼續吧

四、運行多個協程

• 常常同一個項目中有多個協程

• 需要借助 asyncio.gather 函數運行

import asyncio
# 通過 async 定義一個協程
async def task1(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
print('這里task1結束了')
# 通過 async 定義一個協程
async def task2(s):
print('請等待 {} 秒'.format(s))
await asyncio.sleep(s)
print('這里task2結束了')
# 運行方法一
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))
# 結果如下：
# 請等待 1 秒
# 請等待 3 秒
# 這里task1結束了
# 這里task2結束了

五、run_forever

• 通過run_until_complete 運行協程，協程運行完，程序也就結束退出了

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

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

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

• 我們可以在協程中調用

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

六、多協程中關閉run_forever

• 單個協程中可以通過在協程中關閉，但是如果是兩個以上的協程的時候

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

• 所以我們可以在回調函數中進行關閉

import asyncio, functools
async def task(x):
await asyncio.sleep(x)
print('這是協程任務')
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()

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