同步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())


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
 

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
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
 

参考

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

文章来源: pengshiyu.blog.csdn.net，作者：彭世瑜，版权归原作者所有，如需转载，请联系作者。

原文链接：pengshiyu.blog.csdn.net/article/details/81981561