0
点赞
收藏
分享

微信扫一扫

Python编程:asyncio协程编程


同步IO:

一旦遇到IO操作,如读写文件、发送网络数据时,就需要等待IO操作完成,才能继续进行下一步操作

异步IO:

当代码需要执行一个耗时的IO操作时,它只发出IO指令,并不等待IO结果,然后就去执行其他代码了。一段时间后,当IO返回结果时,再通知CPU进行处理

消息循环:

主线程不断地重复“读取消息-处理消息”

当遇到IO操作时,代码只负责发出IO请求,不等待IO结果,然后直接结束本轮消息处理,进入下一轮消息处理过程。当IO操作完成后,将收到一条“IO完成”的消息,处理该消息时就可以直接获取IO操作结果。

代码示例

1、简单示例

# -*- coding: utf-8 -*-

import asyncio


async def main():
await asyncio.sleep(3)


asyncio.get_event_loop().run_until_complete(main())

2、多任务切换示例

创建3 个任务,每个任务耗时2s ,如果是同步IO则需要​​6s​​ 执行时间。

使用协程多任务切换最终耗时​​2s​​ 多一点点

# -*- coding: utf-8 -*-

import time
import asyncio


async def job(job_id): # async 形式的功能
print("start job: %s" % job_id)
await asyncio.sleep(2) # 等待 2 秒, 期间切换其他任务
print("end job: %s" % job_id)


async def main(_loop):
# 创建 3 个任务, 但是不执行
tasks = [
_loop.create_task(job(job_id)) for job_id in range(0, 3)
]

await asyncio.wait(tasks) # 执行并等待所有任务完成


if __name__ == '__main__':
start = time.time()

loop = asyncio.get_event_loop() # 建立 loop
loop.run_until_complete(main(loop)) # 执行 loop
loop.close() # 关闭 loop

print("time: %s" % (time.time() - start))

"""
start job: 0
start job: 1
start job: 2
end job: 0
end job: 1
end job: 2
time: 2.0042531490325928
"""


参考


  1. ​​加速爬虫: 异步加载 Asyncio​​
  2. ​​廖雪峰-异步IO​​




举报

相关推荐

0 条评论