协程系列之Event Loops

Event Loops

事件循环

事件是由程序的一部分在特定条件下发出的消息，循环是在某种条件下完成并执行某个程序直到它完成的构造，所以，事件循环是一个循环，它容许用户订阅事件传输并注册处理程序/回调。 它使程序可以以异步方式运行。事件循环将它收到的全部事件委托给各自的回调，大多数回调模式的实现都有一个主要缺点，他们以引入大量嵌套的方式规定编程风格。所以，为了表示程序的某些部分彼此依赖，咱们使用排序，然而，在依赖于异步结果的状况下，出现了如下模式：

• 嵌套回调，以便内部回调能够访问外部回调的结果（闭包）
• 使用充当将来结果代理的对象（所谓的 Future 或 Promise ）
• 协程，它是在事件循环中运行的可挂起函数

Nesting Callback（嵌套回调）

嵌套回调的经验法则是，若是须要等待回调的结果，则必须将代码嵌入到相应的回调中。你很快就会陷入臭名昭着的回调地狱般的局面。回调地狱是回调嵌套的深度，这使得程序的推理和改进成为一种噩梦。

Futures/Promises

Futures/Promises 是封装异步调用的结果和错误处理的对象。它们最终会提供 APIs 来查询results/exceptions 的当前状态，以及注册回调来处理 results/exceptions 的方法。因为它们封装了异步调用的将来上下文并须要嵌套，所以生成的程序彷佛以更自上而下的方式编写。(.then那种形式)

Coroutines

你能够简单把协程理解为能够中断的函数。暂停意味着咱们能够在函数任何位置暂停协程。这意味着它必定有某种原子单位组成。这就是咱们所说的 tick，也就是咱们所测量的 tick。tick 是事件循环的时间单位， 它包含在事件循环的一个迭代步骤中发生的全部操做

协程实际上能够作得更多：它们能够暂停本身并等待另外一个协同程序的结果。 waiiting 的全部逻辑由事件循环协调，由于它知道相应的协程状态

Asyncio中事件循环的生命周期

asyncio中的事件循环有四种状态： 1.Idle 2.Running 3.Stopped 4.Closed 您能够经过四种事件循环方法与事件循环的生命周期进行交互，这些方法能够分为启动，中止和关闭方法。 它们构成了事件循环生命周期接口，全部 asyncio /第三方事件循环都须要提供兼容性。

1.run_forever 2.run_until_complete

调用 run_forever 方法时没有参数，而 run_until_complete 方法须要传入一个协程函数做为参数。要中止，咱们可使用 stop 方法；要关闭，咱们使用 close 方法。

The Idle State(空闲状态)

空闲状态是建立循环后所处的状态。在此状态下不消耗任何协程或者回调函数。在这个状态下 loop.is_running 返回 False。

The Running State(运行状态)

运行状态是在调用 loop.run_forever 或 loop.run_until_complete 以后循环所处的状态。在这个状态下 loop.is_running 返回 True。 这些方法之间的区别在于，在 loop.run_until_complete 的状况下，loop.run_until_complete 会将协程被包装在 asyncio.Future 中。回调在 asyncio.Future 对象上注册为处理程序，该对象在彻底消耗协程后运行loop.stop 方法。

The Stopped State(中止状态)

中止状态是调用stop命令后循环所处的状态。调用stop方法后，调用is_running方法不会返回False，首先消耗全部挂起的回调。只有在它们被消耗以后，循环才会进入空闲状态。

The Closed State(关闭状态)

循环经过调用close方法进入关闭状态。只有当循环不处于运行状态时，才能调用它。

事件循环的基本类

在Python 3中默认提供两种事件循环。 抽象事件循环类由asyncio.events和asyncio.base_events模块提供。 AbstractEventLoop和BaseEventLoop表示事件循环实现的两个潜在类。

AbstractEventLoop

AbstractEventLoop类定义了原生asyncio中事件循环的接口。 接口方法能够大体分为如下几个部分

• 生命周期方法(运行、中止、查询状态和关闭循环)
• 调度方法
• 回调
• 协程
• 建立Future对象
• 线程相关的方法
• IO操做相关的方法
• 低层级API(socket, pipe, and reader/writer APIs)
• 高层级APIs(server, pipe, and subprocess-related methods)
• 信号方法
• 调试标志管理方法

该应用编程接口是稳定的，在手动事件循环实现的状况下能够被子类化

BaseEventLoop

尽管基于更高级别的组件，但不该使用BaseEventLoop类来建立手动循环实现，由于它的API不稳定。 但它能够做为一个如何实现接口的指南。 它的BaseEventLoop._run_once方法在循环的每一个tick上调用，所以包含一次迭代所需的全部操做。这将调用全部当前准备好的回调，I/O轮询，调度生成的回调，而后调度call_later回调，若是您计划本身实现事件循环，则须要提供与其相似的方法，函数的名称和主体只是实现细节。

事件循环是特定于操做系统的吗？

是的，事件循环是特定于操做系统的 这可能会影响API可用性和事件循环的速度。 例如，add_signal_handler和remove_signal_handler是仅限UNIX的循环API。 除了缺乏相应的本机绑定以外，操做系统特性背后的缘由之一是大多数环路都是基于selectors模块实现的。selectors是基于select模块的提升的高级I/O多路复用接口。 selectors模块创建在Select, poll, devpoll, epoll, or kqueue之上，具体取决于底层操做系统。selectors模块中的模块负责设置默认选择器，而默认选择器又被异步模块使用。

if 'KqueueSelector' in globals():
   DefaultSelector = KqueueSelector
elif 'EpollSelector' in globals():
   DefaultSelector = EpollSelector
elif 'DevpollSelector' in globals():
   DefaultSelector = DevpollSelector
elif 'PollSelector' in globals():
   DefaultSelector = PollSelector
else:
  DefaultSelector = SelectSelector

注意在Windows中还有一个基于I/o完成端口或短IoCP的ProactorEventLoop类实现 IOCP的官方文件将它们描述为“在多处理器系统上处理多个异步输入输出请求的有效线程模型”。例如，若是须要使用asyncio子进程API，能够在Windows上使用ProactorEventLoop。 后续，会不断完善。 更多精彩内容请关注公众号:python学习开发