无法将可等待传递给 asyncio.run_coroutine_threadsafe

我观察到asyncio.run_coroutine_threadsafe函数不接受一般的可等待对象，我不明白这种限制的原因。观察

import asyncio


async def native_coro():
    return


@asyncio.coroutine
def generator_based_coro():
    return


class Awaitable:
    def __await__(self):
        return asyncio.Future()


loop = asyncio.get_event_loop()

asyncio.run_coroutine_threadsafe(native_coro(), loop)
asyncio.run_coroutine_threadsafe(generator_based_coro(), loop)
asyncio.run_coroutine_threadsafe(Awaitable(), loop)

使用 Python 3.6.6 运行它会产生结果

Traceback (most recent call last):
  File "awaitable.py", line 24, in <module>
    asyncio.run_coroutine_threadsafe(Awaitable(), loop)
  File "~/.local/python3.6/lib/python3.6/asyncio/tasks.py", line 714, in run_coroutine_threadsafe
    raise TypeError('A coroutine object is required')
TypeError: A coroutine object is required

其中第 24 行是asyncio.run_coroutine_threadsafe(Awaitable(), loop).

我知道我可以将可等待对象包装在定义如下的协程中

awaitable = Awaitable()

async def wrapper():
    return await awaitable

asyncio.run_coroutine_threadsafe(wrapper(), loop)

然而我的期望是等待将是直接有效的论点run_coroutine_threadsafe.

我的问题是：

1. 这个限制的原因是什么？
2. Is the wrapper上面定义的函数是传递可等待的最传统方法run_coroutine_threadsafe以及其他需要的 APIasync def或者生成器定义的协程？

这个限制的原因是什么？

看着执行 https://github.com/python/cpython/blob/98b976a2f82ba5f50cf6846338f644ca6c64f47d/Lib/asyncio/tasks.py#L821，原因肯定不是技术性的。由于代码已经调用ensure_future（而不是说，create_task），它会自动工作，并且在任何可等待的对象上正确工作。

限制原因可以在跟踪器上找到。该功能于 2015 年添加，原因是拉取请求 https://github.com/python/asyncio/pull/273。在相关讨论中业务流程外包问题 https://bugs.python.org/issue25304提交者明确请求将函数重命名为ensure_future_threadsafe（平行于ensure_future）并接受任何类型的等待，这是尤里·塞利瓦诺夫（Yury Selivanov）附议的立场。然而，吉多against https://bugs.python.org/msg252270想法：

我反对这个想法。不管怎样，我并没有真正看到这种方法有多么重要的未来：它只是线程世界和异步世界之间的一点粘合剂，人们将通过查找示例来学习如何使用它。

[...]

但老实说我don't希望鼓励在线程和事件循环之间来回翻转；我认为这是一种必要的罪恶。从在线程世界中编码的某人想要将某些内容移交给异步世界的人的角度来看，我们目前使用的名称很好。

为什么线程世界中的某人需要等待 asyncio.future？听起来他们正在混淆这两个世界——或者他们应该编写异步代码而不是线程代码。

还有其他类似的评论，但以上内容几乎总结了这一论点。

Is the wrapper上面定义的函数是传递可等待的最传统方法run_coroutine_threadsafe以及其他需要异步 def 或生成器定义的协程的 API？

如果您确实需要一个协程对象，例如wrapper这无疑是一种简单而正确的获取方法。

如果您创建包装器的唯一原因是调用run_coroutine_threadsafe，但你实际上对结果或concurrent.futures.Future由返回run_coroutine_threadsafe，您可以通过调用来避免换行call_soon_threadsafe直接地：

loop.call_soon_threadsafe(asyncio.ensure_future, awaitable)