今天开始聊一聊python3的asyncio。关于asyncio，大家肯定都有自己的理解，并且网上大神也把基础概念也解释的比较透彻。
本文写作的初衷，主要是理解asyncio的原理并且实现一遍。
话不多说，我们开始！
● 理解进程、线程、协程。简单来说，这三个都是为了解决多任务同时进行的问题
1）进程是操作资源分配的最小单位，多任务的实现主要是极快地在进程间来回切换，而进程切换消耗时间最长（系统调用）
2）线程依赖于进程，多个线程共享了父进程的一部分资源，线程切换时间相对于进程来说消耗时间大大减少，但是由于python gil的存在，并不存在多线程（系统调用）
3）协程依赖于线程，由于进程/线程切换都是系统调用，开销是巨大的。而协程是在用户空间内完成任务切换，不会切换到操作系统资源（寄存器、信号量、堆栈等），所以这种方式开销最小。python的协程核心在于，遇到等待事件，就交出cpu控制权，转而让其他协程执行
● 理解python生成器，yield/yield from
这里就不班门弄斧了，直接推荐大佬的blog
● 理解关键字async/await，async/await是3.5之后的语法，和yield/yield from异曲同工
先来看下官方asyncio的使用方法：
|># more main.py
import asyncio
async def hello():
print('enter hello ...')
return 'world'
if __name__ == "__main__":
loop = asyncio.get_event_loop()
task = loop.create_task(hello())
rst = loop.run_until_complete(task)
print(rst)
|># python3 main.py
enter hello ...
world
来看下造的轮子的使用方式：
▶ more main.py
from wilsonasyncio import get_event_loop
async def hello():
print('enter hello ...')
return 'world'
if __name__ == "__main__":
loop = get_event_loop()
task = loop.create_task(hello())
rst = loop.run_until_complete(task)
print(rst)
▶ python3 main.py
enter hello ...
world
自己造的轮子也很好的运行了，下面我们来看下轮子的代码
1）代码组成
|># tree
.
├── eventloops.py
├── futures.py
├── main.py
├── tasks.py
├── wilsonasyncio.py
2）代码概览：
eventloops.py
tasks.py
futures.py
3）执行过程
3.1）入口函数
main.py
async def hello():
print('enter hello ...')
return 'world'
if __name__ == "__main__":
loop = get_event_loop()
task = loop.create_task(hello())
rst = loop.run_until_complete(task)
print(rst)
loop = get_event_loop()获取事件循环task = loop.create_task(hello())将用户函数hello()封装成协程，我们看下create_task的源码
def create_task(self, coro):
task = tasks.Task(coro, loop=self)
return task
初始化一个Task对象，从代码概览得知，初始化对象之后会立即将__step添加到_ready队列等待执行
rst = loop.run_until_complete(task)开始执行事件循环的第一个函数run_until_complete
3.2）事件循环启动
eventloops.py
def run_until_complete(self, future):
future.add_done_callback(_complete_eventloop, future)
self.run_forever()
return future.result()
future.add_done_callback(_complete_eventloop, future)为future添加回调函数（future就是task对象，而task对象里的任务就是hello()），回调函数是_complete_eventloop。就是future执行完成之后执行_complete_eventloopself.run_forever()启动事件循环
3.3）第一次循环run_forever --> run_once
eventloops.py
def run_once(self):
ntodo = len(self._ready)
for _ in range(ntodo):
handle = self._ready.popleft()
handle._run()
- 将
_ready队列的内容（task.__step）取出来执行
tasks.py
def __step(self, exc=None):
coro = self._coro
try:
if exc is None:
coro.send(None)
else:
coro.throw(exc)
except StopIteration as exc:
super().set_result(exc.value)
finally:
self = None
coro.send(None)核心代码，跳转回到用户函数hello()
main.py
async def hello():
print('enter hello ...')
return 'world'
- 用户函数非常简单，打印一行数据，以及返回一个字符串
world，执行完成之后回到task.__step() super().set_result(exc.value)由于用户函数执行完成，会抛出异常StopIteration，捕获之后执行set_result- 由代码概览得知
set_result的作用在于将任务状态置位_FINISHED，并且将回调函数（_complete_eventloop）写入_ready队列
3.4）第二次循环run_forever --> run_once
eventloops.py
def run_once(self):
ntodo = len(self._ready)
for _ in range(ntodo):
handle = self._ready.popleft()
handle._run()
- 继续循环，
handle封装了_complete_eventloop
def _complete_eventloop(fut):
fut._loop.stop()
- 调用stop，设置停止标志
3.5）第三次循环run_forever
def run_forever(self):
while True:
self.run_once()
if self._stopping:
break
- 跳出事件循环，回到
run_until_complete
def run_until_complete(self, future):
future.add_done_callback(_complete_eventloop, future)
self.run_forever()
return future.result()
3.6）回到主函数，获取返回值
if __name__ == "__main__":
loop = get_event_loop()
task = loop.create_task(hello())
rst = loop.run_until_complete(task)
print(rst)
rst = loop.run_until_complete(task)获取返回值
3.7）执行结果
▶ python3 main.py
enter hello ...
return world ...
● task对象与future有什么区别？主要用于整个协程运行的周期，主要负责与用户函数进行交互
● 本文从asyncio的第一个函数run_until_complete，介绍了asyncio的基本流程：用户函数并不是立即执行，而是进入队列，然后根据eventloop在合适的时机进行统一调度
● 本文中的代码，参考了python 3.7.7中asyncio的源代码，裁剪而来
● 本文中代码：代码
至此，本文结束
在下才疏学浅，有撒汤漏水的，请各位不吝赐教...