aevent 0.1.1

支持函数

aevent 以两种方式猴子补丁 anyio 的 TaskGroup.spawn。

• 子任务被仪器化以支持 greenback。

• spawn 返回一个取消范围。您可以使用它来取消新任务。

如果您以其他方式启动任务，请在子任务中调用 aevent.per_task。

线程

线程被转换为任务。为了使其正常工作，您必须以 aevent.run 启动程序，或者在一个 aevent.runner 异步上下文中运行相关的同步代码。运行器可以嵌套。

尚未支持

• select

  • 其他内容

• dns

• os

  • read

  • write

• ssl

• subprocess

• signal

子类化修补的类

直接从 aevent 修补的类中派生并不起作用，需要特殊考虑。考虑以下代码

class my_thread(threading.Thread):
   def run(self):
       ...

与 aevent 一起使用时，您可以选择原始的 Thread 实现

orig_Thread = getattr(threading.Thread, "_aevent_orig", threading.Thread)
class my_thread(orig_Thread):
  ...

或 aevent-化的版本

new_Thread = threading.Thread._aevent_new # fails when aevent is not loaded
class my_thread(new_Thread):
  ...

或者您可能想创建两个独立的实现，并根据 aevent 上下文进行切换

class _orig_my_thread(threading.Thread._aevent_orig):
   ...
class _new_my_thread(threading.Thread._aevent_new):
   ...
my_thread = aevent.patch__new_my_thread, name="my_thread", orig=_orig_my_thread)

如果您动态生成本地子类，可以将此简化为

def some_code():
    class my_thread(threading.Thread._aevent_select()):
        def run(self):
            ...
    job = my_tread()
    my_thread.start()

其他受影响的模块

您需要在导入 aevent 之前导入任何需要非修补代码的模块。

已知受影响的模块

• multiprocessing

测试

测试套件使用 trio 作为后端运行。由于 aevent 的猴子补丁，不支持切换后端。但是，您可以设置环境变量 AEVENT_BACKEND 为 asyncio，以使用该后端运行测试套件。

测试套件拉取了 pyroute2 的副本（除了修复与 aevent 无关的错误之外，没有其他更改），并对其测试套件进行测试，从而（主要是）确保该特定包与 aevent 兼容。