我用的是带有公共汽车的高速公路网络套接字。
我有一个服务,它获取数据并收集数据,并将其放在Redis中的一个主题中。
然后,我想听新的消息,然后发布到一个主题与高速公路公共潜艇。当函数退出时,它可以正常工作,但当我将其放入for循环(经常侦听新的redis消息)时,它不会发布任何内容。
我认为这是因为这阻碍了反应堆实际发布数据。Iv试图调查deferToThread,但这不起作用。
我在想,有没有人知道我怎么能在一段时间循环中发布数据到高速公路主题。
谢谢
发布于 2013-12-19 22:29:16
您可以在后台线程上的阻塞循环中连接到Redis,在Twisted中,deferToThread
是实现这一目的的一种方法,但只有一半:另一半是使用callFromThread
调用运行在主线程上的Autobahn的发布/分发。
您可以在这里阅读更多内容:http://twistedmatrix.com/documents/13.2.0/core/howto/threading.html
https://stackoverflow.com/questions/20692494
复制相似问题