18.5.2. 事件循环¶

源码: Lib/asyncio/events.py

18.5.2.1. 事件循环函数¶

下面的函数是访问全局策略方法的便利快捷方式。注意这只是提供了对默认策略的访问，除非要在进程开始之前设置替代的策略。

asyncio.get_event_loop()¶: 与调用 get_event_loop_policy().get_event_loop() 等价。

asyncio.set_event_loop(loop)¶: 等价于调用 get_event_loop_policy().set_event_loop(loop)。

asyncio.new_event_loop()¶: 等价于调用 get_event_loop_policy().new_event_loop()。

18.5.2.2. 可用的事件循环¶

asyncio当前提供两种事件循环实现： SelectorEventLoop 和 ProactorEventLoop 。

class asyncio.SelectorEventLoop¶

基于 selectors 模块的事件循环。 AbstractEventLoop 的子类。

使用对应平台上最高效的选择器。

在Windows上，只支持套接字（举例：不支持管线）：参见 MSDN关于select的文档 <https://msdn.microsoft.com/en-us/library/windows/desktop/ms740141%28v=vs.85%29.aspx> _ 。

class asyncio.ProactorEventLoop¶

Windows上的 Proactor 事件循环，使用的是 “I/O 完成端口”，也叫做 IOCP。为 AbstractEventLoop 的子类。

可用性：Windows。

参见

MSDN上关于 I/O完成端口的文档。

在Windows上使用 ProactorEventLoop 的例子:

import asyncio, sys

if sys.platform == 'win32':
    loop = asyncio.ProactorEventLoop()
    asyncio.set_event_loop(loop)

18.5.2.3. 平台支持¶

asyncio 模块被设计为可移植的，但是每个平台仍旧有细微的不同，而且不一定支持 asyncio 的所有特性。

18.5.2.3.1. Windows¶

Windows事件循环的一般限制：

不支持 create_unix_connection() 和 create_unix_server()：socket.AF_UNIX 套接字族只在UNIX上可用
不支持 add_signal_handler() 和 remove_signal_handler()
不支持 EventLoopPolicy.set_child_watcher() 。ProactorEventLoop 支持子进程。监控子进程的实现只有一种，不需要对其进行设置。

特定于 SelectorEventLoop 的限制：

SelectSelector 只被用于支持套接字，并且最多支持512个套接字。
add_reader() 和 add_writer() 只接受套接字的文件描述符
不支持管线（示例：connect_read_pipe(), connect_write_pipe()）
不支持 Subprocesses （示例: subprocess_exec(), subprocess_shell()）

特定于 ProactorEventLoop 的限制：

不支持 create_datagram_endpoint() (UDP)
不支持 add_reader() 和 add_writer()

Windows上单调时钟的分辨率大约为 15.6 毫秒。最佳的分辨率是 0.5 毫秒。分辨率依赖于具体的硬件（HPET 的可用性）和Windows的设置。参见:ref:asyncio delayed calls <asyncio-delayed-calls> 。

在 3.5 版更改: ProactorEventLoop 现在支持SSL了。

18.5.2.3.2. Mac OS X¶

类似于PTY的字符设备在Mavericks （Mac OS 10.9）之前并未有很好的支持。在 Mac OS 10.5以及更老的版本上则根本不支持。

在Mac OS 10.6、10.7和10.8上，默认的事件循环是 SelectorEventLoop ，其使用了 selectors.KqueueSelector 。 selectors.KqueueSelector 在这些版本上并不支持字符设备。SelectorEventLoop 可用同 SelectSelector 或者 PollSelector 一同使用来在这些版本的Mac OS X上支持块设备。例如:

import asyncio
import selectors

selector = selectors.SelectSelector()
loop = asyncio.SelectorEventLoop(selector)
asyncio.set_event_loop(loop)

18.5.2.4. 事件循环策略和默认策略¶

使用一个策略模式对事件循环进行管理，用以为特定平台和框架提供最大限度的灵活性。在一个进程的执行中，唯一的全局策略对象，基于调用的上下文，管理着此进程所有可用的事件循环。一个策略就是一个实现了 AbstractEventLoopPolicy 的对象。

对于 asyncio 的多数使用者来说，从来都不需要显式地处理策略，因为默认的全局策略就已经足够了（看下面）。

模块级别的函数 get_event_loop() 和 set_event_loop() 对于默认策略管理的事件循环的便利访问方式。

18.5.2.5. 事件循环策略接口¶

一个事件循环必须实现如下的接口：

class asyncio.AbstractEventLoopPolicy¶

事件循环策略。

get_event_loop()¶

为当前上下文获取事件循环。

返回一个实现了 AbstractEventLoop 接口的事件循环对象。如果是从一个协程中调用，就会返回当前正在运行的事件循环。

如果没有为当前上下文设置一个事件循环，并且当前策略不能创建一个事件循环，就会抛出一个错误。其务必不能返回 None 。

在 3.6 版更改.

set_event_loop(loop)¶: 将当前上下文的事件循环设置为 loop 。

new_event_loop()¶

根据策略的规则，创建并返回一个新的事件循环对象。

如果有需要设置这个循环作为当前上下文的事件循环，就必须显式调用 set_event_loop() 。

The default policy defines context as the current thread, and manages an event loop per thread that interacts with asyncio. If the current thread doesn’t already have an event loop associated with it, the default policy’s get_event_loop() method creates one when called from the main thread, but raises RuntimeError otherwise.

18.5.2.6. 访问全局循环策略¶

asyncio.get_event_loop_policy()¶: 获取当前事件循环策略。

asyncio.set_event_loop_policy(policy)¶: 设置当前事件循环策略。如果 policy 为 None ，就会恢复使用默认的策略。

18.5.2.7. 自定义事件循环策略¶

要实现一个新的事件循环策略，推荐你继承具体的默认事件循环策略 DefaultEventLoopPolicy 并且重写你想要改变行为的方法，例如:

class MyEventLoopPolicy(asyncio.DefaultEventLoopPolicy):

    def get_event_loop(self):
        """Get the event loop.

        This may be None or an instance of EventLoop.
        """
        loop = super().get_event_loop()
        # Do something with loop ...
        return loop

asyncio.set_event_loop_policy(MyEventLoopPolicy())