我一直在使用Pyro,但我不知道如何处理生产者或消费者线程。理想情况下,使用者应该派生一个线程来向它的两个邻居发送请求。邻居可以是消费者或生产者,并将请求转发给他们的邻居。到目前为止,我得到的是一个Pyro类,如下所示: import threading
def __init__():producerid, forwarder_id(so that the message is not sent backwards) 我试图使Peer类成为threading.
我正试图强化一种用于生产的Pyro应用程序。我在Name Server上遇到了以下问题。如果名称服务器被关闭并迅速打开,则它抛出以下错误的可能性似乎为50%:这可以通过运行窗口中的名称服务器(pyro4我正在使用supervisord来控制Pyro。我发现下面的配置改进了一些问题。值得注意的是,startretries=50总是比30秒还要长,大约需要NameServer才能释放套接字。[program:pyro-ns]
co