带有阻塞while循环的异步执行

Question

所以这是我的方案。我有一个 python 脚本，它在一个无限循环中运行，它接受用户输入。

但是我现在希望另一个函数在阻塞的主循环（等待 python 的 input() 函数）仍在运行时每隔 n 秒执行一次操作。我研究了异步和调度，但它们似乎不适用于阻塞函数调用，还是我弄错了？

我已经研究过多处理，但还不能完全理解我应该如何做。

编辑：

if __name__ == "__main__":
    def survivor():
        count = 5
        while count:
            print("alive")
            time.sleep(8)
            count -= 1
        print("done")


    test = JobChainClient()

    cli = threading.Thread(name="cli", target=test.getShell())
    network = threading.Thread(name="network", target=survivor())

    cli.start()
    network.start()
    print("Done")

此代码获取我的 CLI，它是一个无限的 while 循环和我的网络守护程序。当我运行它时，它显然可以工作，但问题是：

(JobChain) > exit
Closing JobChain client now!
alive
alive
alive

我的循环在退出命令后中断，只有另一个线程开始，我可能只是在这里遗漏了一些东西，请纠正我。

Answer 1

您不能同步阻止用户输入。每个阻塞 = 阻塞线程，它应该同时处理您的其他请求。

为了从异步编程模式中获得最大收益，您必须在任何地方使用 async。

主要思想是有一个没有任务阻塞的事件循环。任务应该尽快返回某种承诺，即它将在未来的某个时间以返回值实现。然后 eventloop 可以继续并立即处理您的下一个任务。

如果你真的需要同步阻塞，你应该生成新线程来执行 cpu 密集型绑定任务。

Answer 2

最简单的解决方案是在单独的线程中调用这个其他函数（每 n 秒执行一次）。

如果您想使用 asyncio，请查看 aioconsole，它提供了 input() 的异步等效项。

编辑
关于更新的问题，正确的开帖方式是：

# note the lack of parentheses after `getShell` - you only
# want to refer to the function, not to call it (yet)
cli = threading.Thread(name="cli", target=test.getShell)
cli.start()