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

2024年1月13日 340次阅读

当我通过
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()方法,在.calculateSomeStuff()开始执行它的工作之后,我该怎么改变才能让这个程序返回is_busy？

据我所知,没有办法让它在python 2中异步.

最佳答案 您需要多线程才能实现真正的并发性并利用多个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)几次,你会有多线程的错觉.

我希望我的答案不会太混乱.

点赞