我怎样才能“醒来”？一个事件循环来通知它另一个线程的 Future 已完成？

Question

使用Python async/asyncio时，我经常创建并完成asyncio.future来自不是线程的线程的对象，这些线程不是线程运行事件循环的线程。

除非我完成正在运行事件循环的线程中的那些未来或通过通知完成循环的函数，否则事件循环通常不会“注意”期货已完成。

是否有一种方法可以“通知”事件循环，如果在外部（通过set_result）外部（通过set_result）在外部（通过SET_RESULT）检查未来是否应该检查未来？

为什么我要问这个

线程）延迟非常低，b）检查是否已同步，以后同步（例如future.done.done（））。

事件循环等待期货不是 需要较低的延迟，以通知他们准备就绪 - 可以迟到几毫秒通知几毫秒。

理想情况下，将有一种表现方式来通知事件循环，即在线程中同步准备后就准备好了未来。

即使不可能，只要期货在线程中尽快完成期货，事件循环也可以在间隔内进行轮询准备。

我尝试了

解决此问题的“正确”方法是call_soon_threadsafe，例如：

def do_in_thread(future):
    future.get_loop().call_soon_threasafe(future.set_result, "the result")

它通知事件循环未来的准备就绪，但没有

1. 有两个原因（8--） 。 10x）开销与调用future.set_result在我的基准测试中。
2. 在事件循环运行之前，它没有准备好未来，这意味着我无法可靠地检查未来是否完成，我需要做。例如，这是行不通的：

def do_in_thread(future):
    future.get_loop().call_soon_threasafe(future.set_result, "the result")
    assert future.done()  # Fails

看起来 工作的一件事是通过故意失败a second 调用set_result 通过call_soon_threadsafe，然后吞咽invalidStateError，像这样：

def ensure_result(f, res):
    try:
        f.set_result(res)
    except InvalidStateError:
        pass


def in_thread(fut: Future):
    fut.set_result("the result")
    fut.get_loop().call_soon_threadsafe(ensure_result, fut, "the result")

仍然有开销，但是我可以通过跟踪未来的未来来删除调用call_soon_threadsafe在线程共享的数据结构和轮询suars_result中，偶尔会呼叫。但是，我仍然不确定：

1. 这可靠地起作用吗？是set_result invalidStateError保证通知事件循环的等待给定的未来可以返回等待，还是我依靠的无证件实现细节？
2. 有没有更好的方法来实现这一定期罢工，这并不涉及我自己跟踪/轮询这样的未来？

在一个完美的世界中，会有一个loop.poll_all_pending_futures（）或loop.update_future_state（fut）方法可以有效地实现这一目标，但我不知道一个。

Answer 1

免责声明：这可能不是未来的证明或处理所有事件循环
上下文。

我遇到了同样的基本问题，并且几天来我的头撞在墙上。我使用 C++ 扩展中的回调通过在另一个系统线程（在 C 端创建）中运行的代码来设置未来结果。我可以设置未来的结果，但事件循环并不关心，除非我有其他协程使其在该 Python 线程中保持“活动”，即使如此，它通常也很慢。

我使用这个概念解决方案（针对您的示例代码发布）来解决它：

def in_thread(fut: Future):
    fut.set_result("the result")
    asyncio.run_coroutine_threadsafe( asyncio.sleep(0), fut.get_loop() )

结果是在设置未来和让事件循环“唤醒”并处理它之间有大约 100 微秒（不是毫，微）的延迟。