快捷導(dǎo)航

python?中的?asyncio?異步協(xié)程

更新時(shí)間：2022年04月27日 10:49:34 作者：autofelix

這篇文章主要介紹了python?中的?asyncio?異步協(xié)程?IO?教程，asyncio?執(zhí)行的任務(wù)，稱為協(xié)程，但是Asyncio?并不能帶來(lái)真正的并行，下文具體的相關(guān)資料感興趣的小伙伴可以參考一下

一、定義協(xié)程

asyncio 執(zhí)行的任務(wù)，稱為協(xié)程，但是Asyncio 并不能帶來(lái)真正的并行
Python 的多線程因?yàn)?GIL（全局解釋器鎖）的存在，也不能帶來(lái)真正的并行

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

二、運(yùn)行協(xié)程

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

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

加入我們處理完協(xié)程任務(wù)后，需要告訴開(kāi)發(fā)人員，這里程序結(jié)束了
就需要使用到協(xié)程回調(diào)

import asyncio
# 通過(guò) async 定義一個(gè)協(xié)程
async def task(s):
print('請(qǐng)等待 {} 秒'.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é)果如下：
# 請(qǐng)等待 3 秒
# 這里task結(jié)束了，其他的繼續(xù)吧

四、運(yùn)行多個(gè)協(xié)程

常常同一個(gè)項(xiàng)目中有多個(gè)協(xié)程
需要借助 asyncio.gather 函數(shù)運(yùn)行

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

五、run_forever

通過(guò)run_until_complete 運(yùn)行協(xié)程，協(xié)程運(yùn)行完，程序也就結(jié)束退出了
使用run_forever 運(yùn)行，程序并不會(huì)退出，除非調(diào)用 loop.stop()

import asyncio
# 通過(guò) async 定義一個(gè)協(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
# 通過(guò) async 定義一個(gè)協(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

單個(gè)協(xié)程中可以通過(guò)在協(xié)程中關(guān)閉，但是如果是兩個(gè)以上的協(xié)程的時(shí)候
如果有一個(gè)協(xié)程先做完了就stop了，將會(huì)導(dǎo)致其他的協(xié)程也會(huì)異常退出，這肯定是不允許的
所以我們可以在回調(diào)函數(shù)中進(jìn)行關(guān)閉

import asyncio, functools
async def task(x):
await asyncio.sleep(x)
print('這是協(xié)程任務(wù)')
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é)程 IO 教程的文章就介紹到這了,更多相關(guān)python 異步協(xié)程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: