python - 如何使用 zeromq 和线程或异步处理对 python 程序的多个请求？

Question

我有一个小程序，当我通过 python 2.7 中的 zerorpc 模块调用它时，它会在后台进行一些计算。

这是我的代码:

is_busy = False

class Server(object):
   def calculateSomeStuff(self):
       global is_busy

        if (is_busy):
            return 'I am busy!'

        is_busy = True

        # calculate some stuff

        is_busy = False
        print 'Done!'
        return 

    def getIsBusy(self):
        return is_busy

s = zerorpc.Server(Server())
s.bind("tcp://0.0.0.0:66666")
s.run()

我应该改变什么来使这个程序在我调用 .getIsBusy() 方法时返回 is_busy，在 .calculateSomeStuff() 开始执行它的工作之后？

据我所知，在 python 2 中无法使其异步。

Answer 1

您需要多线程来实现真正的并发，并且如果这是您所追求的，则可以利用多个 CPU 内核。请参阅 Python 线程模块 GIL-lock 详细信息和可能的解决方法以及文献。

如果您想要合作解决方案，请继续阅读。

zerorpc 使用 gevent 进行异步输入/输出。使用 gevent，您可以编写协同程序(也称为 greenlet 或 userland 线程)，它们都在单个线程上协同运行。 gevent 输入输出循环运行的线程。 gevent ioloop 负责恢复等待某些 I/O 事件的协程。

这里的关键是合作这个词。将其与在单个 CPU/核心机器上运行的线程进行比较。实际上没有并发，
但操作系统会抢占_{(动词:采取行动以防止(预期事件)发生)} 正在运行的线程执行下一个等等，以便每个线程都有公平的机会继续前进。

这发生得足够快，以至于感觉所有线程都在同时运行。

如果您将代码与 gevent 输入/输出循环配合使用，则可以通过小心调用 gevent.sleep(0) 来达到相同的效果> 经常足以让 gevent ioloop 有机会运行其他协程。

它实际上是协作式多线程。我听说在 Windows 2 或其他系统中就是这样。

因此，在您的示例中，在繁重的计算部分，您可能正在进行一些循环。确保每秒调用 gevent.sleep(0) 几次，您会产生多线程的错觉。

我希望我的回答不会太困惑。