python 中的 asyncio 异步协程
作者:autofelix 时间:2022-09-15 12:30:53
一、定义协程
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()
来源:https://blog.51cto.com/autofelix/5256821
标签:python,asyncio,异步,协程
0
投稿
猜你喜欢
描述性列表的表现形式
2008-09-17 13:43:00
MYSQL教程:保证安全的备份MYSQL数据库的方法
2010-03-03 17:12:00
spyder快捷键与python符号化输出方式
2023-08-23 11:58:24
不得不承认:韩国的 Web 设计很唯美
2009-05-13 13:26:00
Python实现查找系统盘中需要找的字符
2022-10-02 02:35:50
JavaScript事件委托技术实例分析
2023-07-01 01:18:23
全文译稿 Windows Internet Explorer 8 性能优化白皮书
2010-04-23 20:13:00
np.dot()函数的用法详解
2023-06-14 02:12:21
python通过加号运算符操作列表的方法
2023-11-12 13:44:04
Python实现读取SQLServer数据并插入到MongoDB数据库的方法示例
2022-11-16 04:14:21
asp如何分页显示数据库查询结果?
2009-11-22 19:23:00
请注意页面head区域的编码是不是规范
2008-08-06 13:14:00
Python zip()函数用法实例分析
2022-10-28 21:39:53
asp连接mssql2005的代码
2011-03-29 11:11:00
asp 自定义分段函数/求第N名成绩
2011-03-25 11:07:00
DW实现鼠标滑过切换图片
2008-02-03 18:49:00
Python编写一个闹钟功能
2022-02-14 14:03:08
JavaScript程序执行顺序问题总结
2010-01-29 13:06:00
理清mysql外链的含义和命令
2010-03-09 15:55:00
Sql server 2005 找出子表树
2008-11-24 15:23:00