在 Python 3 中异步等待方法完成

Question

考虑这个简化的例子：

def get_external_thing() -> str:
    my_variable = a_blocking_operation()
    my_variable.some_other_operation()
    return my_variable

externally_gathered_thing = None
while True:
    sleep(1)
    externally_gathered_thing = get_external_thing()
    if externally_gathered_thing:
        do_something_1()
        externally_gathered_thing = None
    do_something_2()

这显然会进入循环，休眠一秒钟，然后进入get_external_thing() 并等待a_blocking_operation() 完成。只要get_external_thing() 正在运行，就不会执行任何其他操作。

如果get_external_thing() 没有完成，我想要完成的是强制我的循环继续并直接转到do_something_2()。但是，如果 get_external_thing() 已经完成并且 externally_gathered_thing 有一些价值，我希望 do_something_1() 也能被执行。

我怎样才能纯粹在 Python 中完成它？我尝试使用这个示例来学习 asyncio，但没有设法生成任何工作示例。由于项目要求，asyncio 是首选，但不是必须的。

换句话说，无论get_external_thing() 的结果如何，我都希望每秒执行一次do_something_2()（或每秒+一些小开销）。

注意：不要被while True 结构吓到，它被设计为在树莓派上连续运行:)

Answer 1

对于此类任务，请查看concurrent.futures 模块。例如：

def get_external_thing() -> str:
    my_variable = a_blocking_operation()
    my_variable.some_other_operation()
    return my_variable

externally_gathered_thing = None
executor = concurrent.futures.ThreadPoolExecutor()
working = None

while True:
    if working is None:
        # if no work is in progress, start the external task in a bg thread
        working = executor.submit(get_external_thing)
    try:
        # wait for the external result, but no more than a second
        externally_gathered_thing = working.result(timeout=1)
        working = None
    except concurrent.futures.TimeoutError:
        # in case of timeout, proceed with our logic anyway, we'll get
        # back to waiting in the next iteration
        pass

    if externally_gathered_thing is not None:
        do_something_1()
        externally_gathered_thing = None
    do_something_2()

基于 asyncio 的解决方案是可能的，但它仍然必须在后台使用线程来等待阻塞操作（这就是 run_in_executor 的工作原理），因此它将 asyncio 的复杂性与线程的复杂性结合起来。