senset/vnpy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

vn.rpc中的zmq socket接收数据前，使用poll等待

Browse Source
This commit is contained in:
chenxy123 2016-12-21 23:30:19 +08:00
parent 49f1a7f0df
commit 0d3fceb9d2
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
vn.rpc/vnrpc.py
View File

@ -149,6 +149,10 @@ class RpcServer(RpcObject):
def run(self): def run(self):
"""服务器运行函数""" """服务器运行函数"""
while self.__active: while self.__active:
# 使用poll来等待事件到达，等待1秒（1000毫秒）
if not self.__socketREP.poll(1000):
continue
# 从请求响应socket收取请求数据 # 从请求响应socket收取请求数据
reqb = self.__socketREP.recv() reqb = self.__socketREP.recv()
@ -266,6 +270,10 @@ class RpcClient(RpcObject):
def run(self): def run(self):
"""客户端运行函数""" """客户端运行函数"""
while self.__active: while self.__active:
# 使用poll来等待事件到达，等待1秒（1000毫秒）
if not self.__socketSUB.poll(1000):
continue
# 从订阅socket收取广播数据 # 从订阅socket收取广播数据
topic, datab = self.__socketSUB.recv_multipart() topic, datab = self.__socketSUB.recv_multipart()