12

我正在尝试移植一个flask应用程序quart以使用asyncio. 我认为我目前的方法行不通，因为我的整个函数链都是在没有考虑异步的情况下编写的 - 请考虑以下几点：

def long_running_task(task):
    result = some_synchronous_function(task)
    return result

@app.route('/<task>', methods=['GET'])
async def do_task(task):
    ok = await long_running_task(task)
    if ok:
        return (ok.result)
    else:
        return ('Something went wrong')

如果long_running_task及其整个函数调用链未声明为async，我实际上是否从我的路由声明中获得任何好处async？

4

1 回答 1

19

要从 asyncio 运行阻塞同步函数，而不阻塞主事件循环，可以使用loop.run_in_executor()在 aThreadPoolExecutor或ProcessPoolExecutor` 中运行阻塞函数（即在其自己的线程或进程中）。

从你想要调用它的异步函数中：

loop = asyncio.get_event_loop()

result = await loop.run_in_executor(None, long_running_task, task)

第一个参数None是告诉它使用循环的默认执行程序。显然do_task()仍然需要等待result完成，但在等待期间，其他异步任务将能够在事件循环中运行。

于 2019-02-14T07:37:18.373 回答