python - 如何在python中使库异步

Question

在我的工作中，他们“利用” Tornado ，但他们没有异步库。是什么让一个库异步，以便它可以更好地适应像 Tornado 这样的东西？有没有什么好的例子，或者我猜你在 __enter__ 或 __exit__ 中做了什么可以表明你没有阻塞？

我发现很难拼凑一些 Material 。

Answer 1

如果您的库不是异步的并且不支持在 tornado ioloop 中运行，那么您唯一能做的就是在其他线程中运行这些任务。

本质上，有两种选择，取决于你是否想要接收返回值:

1. 你把你的工作放在一个队列中，一些线程从队列中拉取工作并处理这些任务 ==> 没有返回值
2. 或者您使用执行程序库 (python 3.2) 并将工作发送到 executor ，添加一个回调以表示任务已完成并将控制权交还给 tornado 的 ioloop(通过卡在循环中的另一个回调)。

如果 your_task_func 是您要卸载到另一个线程的同步任务，则基本上执行以下操作:

def callback(future):
    # here you want to do some stuff with the value future.result()

EXECUTOR.submit(
        your_task_func
        ).add_done_callback(
            lambda future: tornado.ioloop.IOLoop.instance().add_callback(
                partial(callback, future)))

有关此的更多详细信息，请参阅 this nice write-up .

问候马库斯