You are here:  Home » Python » 策略 – – 异步I / O(Python教程)(参考资料)

策略

事件循环策略是一个全局的每个进程对象,用于控制事件循环的管理。每个事件循环都有一个defaultpolicy,可以使用策略API进行更改和自定义.

策略定义了context的概念,并管理每个上下文的单独事件循环。默认策略定义context为当前线程.

使用自定义事件循环策略,get_event_loop(), set_event_loop()new_event_loop()函数的行为可以自定义.

策略对象应该实现AbstractEventLoopPolicy抽象基类中定义的API.

获取和设置策略

以下函数可用于获取并设置当前进程的策略:

asyncio.get_event_loop_policy

返回当前进程范围的策略.

asyncio.set_event_loop_policy (policy

将当前进程范围的策略设置为policy.

如果policy设置为None,则恢复默认策略.

策略对象

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

class asyncio.AbstractEventLoopPolicy

asyncio policies的抽象基类.

get_event_loop

获取当前上下文的事件循环.

返回实现AbstractEventLoop interface.

的事件循环对象这种方法永远不应该返回None.

在版本3.6中改变了

set_event_loop// (loop

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

new_event_loop

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

这个方法永远不应该None.

get_child_watcher

得到一个子进程监视器对象.

返回执行AbstractChildWatcher接口。

这个功能是Unix特有的.

set_child_watcherwatcher

将当前子进程观察器设置为watcher.

此函数是Unix特有的.

asyncio附带以下内置策略:

class asyncio.DefaultEventLoopPolicy

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

无需手动安装默认策略。asynciois配置为自动使用默认策略.

class asyncio.WindowsProactorEventLoopPolicy

使用ProactorEventLoop事件循环实现

可用性:Windows.

加工看守

进程监视器允许自定义事件循环如何监视Unix上的进程。具体来说,事件循环需要在子进程退出时知道.

在asyncio中,使用create_subprocess_exec()loop.subprocess_exec()functions.

asyncio定义AbstractChildWatcher儿童观察者应该实现的抽象基类,并且有两个区别:SafeChildWatcher(配置为默认使用)和FastChildWatcher.

另见子进程和线程section.

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

asyncio.get_child_watcher

返回当前政策的当前儿童观察者.

asyncio.set_child_watcher(watcher)

将当前儿童观察者设置为当前政策的watcherwatcher必须实现AbstractChildWatcher基类.

注意

第三方事件循环实现可能不支持自定义儿童观察者。对于这样的事件循环,使用set_child_watcher()可能被禁止或无效.

class asyncio.AbstractChildWatcher
add_child_handlerpid, callback, *args

注册一个新的子处理程序.

为..作安排 callback(pid, returncode, *args)当一个PID等于的过程被调用pid终止。指定同一进程的另一个回调替换了previoushandler .

callback可调用必须是thread-safe.

remove_child_handlerpid

删除PID等于pid.

该函数返回True如果处理程序被成功删除,False如果没有什么可以移除的话

attach_looploop)

将观察者带到一个事件循环中

如果观察者先前已连接到事件循环,则在连接到新循环之前首先将其分离.

注意:循环可能是None.

close

关闭观察者

必须调用此方法以确保清理底层资源.

class asyncio.SafeChildWatcher

此实现通过在SIGCHLD信号。

这是一个安全的解决方案,但在处理大量进程时会产生很大的开销(O(n)每次SIGCHLD收到).

默认情况下,asyncio使用这个安全的实现.

class asyncio.FastChildWatcher

这个实现通过调用os.waitpid(-1)直接,可能破坏其他代码产生进程并等待终止.

处理大量儿童时没有明显的开销(O(1)每次子进程终止时).

自定义策略

要实现新的事件循环策略,建议继承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 loopasyncio.set_event_loop_policy(MyEventLoopPolicy())

评论被关闭。