在事件循环中等待未来/协程；外部协程

Question

我有一些具有这种结构的代码：

def my_callback():
    loop = asyncio.get_event_loop()
    return loop.run_until_complete(my_coroutine_2())

async def my_coroutine_2():
    return await my_stuff.some_future

async def my_coroutine():
    not_my_code.library_function(my_callback)

在library_function 调用的my_callback 内部，我需要访问和运行协程代码。

但是，run_until_complete 会产生错误：Event loop already running!。

是否有可能完成上面的描述？

也就是说，是否有一个普通的函数调用会导致事件循环暂停当前正在执行的任何协程（即loop.run_until_complete()的调用者），并继续执行其他协程（包括传递给@987654327的那个） @) 直到请求的协程完成，在这种情况下普通函数解除阻塞？

我认为线程可能会有所帮助，但据我了解，所有协程都必须属于同一个线程。

我该怎么做？有可能吗？

Answer 1

假设外部库是线程安全的，您可以使用run_in_executor 在线程外调用它的函数。在等待函数完成时，当前的协程会被阻塞，但事件循环会继续运行。

当您的回调从另一个线程调用时，它可以使用run_coroutine_threadsafe 将协程提交到（仍然功能齐全的）事件循环，并将结果报告回库：

async def my_coroutine():
    loop = asyncio.get_event_loop()
    await loop.run_in_executor(None, not_my_code.library_function,
                               lambda: my_callback(loop))

def my_callback(loop):
    return asyncio.run_coroutine_threadsafe(my_coroutine_2(), loop)