如何使用 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-锁定详细信息和可能的解决方法和文献。

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

zerorpc 将 gevent 用于异步 input/output。使用 gevent，您可以编写协程（也称为 greenlet 或 userland 线程），它们都是运行ning 在单个线程上协同工作。 gevent 输入输出循环为运行ning 的线程。 gevent ioloop 负责恢复协程等待某些 I/O 事件。

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

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

如果你的代码配合geventinput/output循环，小心调用gevent.sleep(0)[=49=也能达到同样的效果] 经常足以给 gevent ioloop 到运行其他协程的机会。

它实际上是协作式多线程。我听说 Windows 2 之类的东西就是这样。

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

希望我的回答不会太混乱。

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

How do I handle multiple requests to python program using zeromq and threading or async?

python

zeromq

python-multithreading

python-2.7

zerorpc