zeromq - 如何在单实例非阻塞 Pyzmq 中运行 REP 和 PUB

Question

我的对象：

class mysrv(object):
    def __init__(self):
        self._pubsocket = context.socket(zmq.PUB)
        self._socket = context.socket(zmq.REP)
        self._socket.bind("tcp://127.0.0.1:9003")
        self._pubsocket.bind("tcp://127.0.0.1:9004")

然后我运行这两个函数：

def main():
    s = mysrv()
    Process(target=s.publoop()).start()
    Process(target=s.reqrep()).start()

第一个功能阻止了第二个。有没有办法从单个类实例运行它们？

Answer 1

答案是，即使被调用while也会阻止所有内容。sleep

因此，whiles在同一进程中不间断地运行多个进程是阻塞的。