Python策略

获取和设置策略¶

可以使用下面函数获取和设置当前进程的策略:

asyncio.get_event_loop_policy()¶

返回当前进程域的策略。

asyncio.set_event_loop_policy(policy)¶

将 policy 设置为当前进程域策略。

如果 policy 设为 None 将恢复默认策略。

策略对象¶

抽象事件循环策略基类定义如下:

class asyncio.AbstractEventLoopPolicy¶

异步策略的抽象基类。

get_event_loop()¶

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

返回一个实现 AbstractEventLoop 接口的事件循环对象。

该方法永远不应返回 None。

在 3.6 版更改.

set_event_loop(loop)¶

将当前上下文的事件循环设置为 loop 。

new_event_loop()¶

创建并返回一个新的事件循环对象。

该方法永远不应返回 None。

get_child_watcher()¶

获取子进程监视器对象。

返回一个实现 AbstractChildWatcher 接口的监视器对象。

该函数仅支持Unix。

set_child_watcher(watcher)¶

将当前子进程监视器设置为 watcher 。

该函数仅支持Unix。

asyncio附带下列内置策略:

class asyncio.DefaultEventLoopPolicy¶

默认asyncio策略。在Unix和Windows平台上都使用 SelectorEventLoop 。

不需要手动安装默认策略。asyncio已配置成自动使用默认策略。

class asyncio.WindowsProactorEventLoopPolicy¶

使用 ProactorEventLoop 事件循环实现的另一种事件循环策略。

可用性: Windows。

进程监视器¶

进程监视器允许定制事件循环如何监视Unix子进程。具体来说，事件循环需要知道子进程何时退出。

在asyncio中子进程由 create_subprocess_exec() 和 loop.subprocess_exec() 函数创建。

asyncio定义了 AbstractChildWatcher 抽象基类，必须由子监视器来实现，可以有两种实现方式：SafeChildWatcher (已配置为默认使用)和 FastChildWatcher 。

请参阅 子进程和线程 部分。

以下两个函数可用于自定义子进程监视器实现，它将被asyncio事件循环使用:

asyncio.get_child_watcher()¶

返回当前策略的当前子监视器。

asyncio.set_child_watcher(watcher)¶

将当前策略的子监视器设置为 watcher 。watcher 必须实现 AbstractChildWatcher 基类定义的方法。

class asyncio.AbstractChildWatcher¶

add_child_handler(pid, callback, *args)¶

注册一个新的子处理回调函数。

安排 callback(pid,returncode,*args) 在进程的PID与 pid 相等时调用。指定另一个同进程的回调函数替换之前的回调处理函数。

回调函数 callback 必须是线程安全。

remove_child_handler(pid)¶

删除进程PID与 pid 相等的进程的处理函数。

处理函数成功删除时返回 True ，没有删除时返回 False 。

attach_loop(loop)¶

给一个事件循环绑定监视器。

如果监视器之前已绑定另一个事件循环，那么在绑定新循环前会先解绑原来的事件循环。

注意：循环有可能是 None 。

close()¶

关闭监视器。

必须调用这个方法以确保相关资源会被清理。

class asyncio.SafeChildWatcher¶

这个实现通过显式地轮询每个进程上的 SIGCHLD 信号来避免中断其他代码洐生进程。

这是一种安全的解决方案，但在处理大量进程时，它会带来很大的开销( O(n) 每次接收到 SIGCHLD )。

asyncio默认使用这种安全的实现。

class asyncio.FastChildWatcher¶

这种实现直接调用 os.waitpid(-1) 来获取所有已结束的进程，可能会中断其它代码洐生进程并等待它们结束。

在处理大量子监视器时没有明显的开销( O(1) 每次子监视器结束)。

自定义策略¶

要实现一个新的事件循环策略，建议子类化 DefaultEventLoopPolicy 并重写需要定制行为的方法，例如:

classMyEventLoopPolicy(asyncio.DefaultEventLoopPolicy):
defget_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 ...
returnloop
asyncio.set_event_loop_policy(MyEventLoopPolicy())