Python：队列.get（）阻止代码检查套接字连接

Question

我正在运行一个线程，它从队列中获取消息，将其发送到客户机，然后接收确认。如果客户端断开连接，线程将捕获套接字错误并终止。问题是如果msgQ是空的，线程就不会检查套接字连接。有没有办法设置这个代码，这样即使队列是空的，也会检查套接字？（问题是，没有消息，就没有要发送的内容）

我需要发送一个特殊的ping吗？彭！消息如果msgQ是空的（并在客户端检查消息是日志数据还是ping？）？任何帮助都将不胜感激。在

def run(self): 
    while not self._terminate: 
        try: 
            msgs = self.msgQ.get()

            self.sock.send(pickle.dumps(msgs))
            rdy = pickle.loads(self.sock.recv(2097152))
        except socket.error, EOFError: 
            print 'log socketmanager closing'
            self.terminate()
            break
        except Empty: pass

Answer 1

我有个主意，就是把队列和管道包装到一个类中。然后使用select模块检查套接字和管道，不会使用轮询来监视事件。在

以下包装队列和管道的示例代码：

class MyQueue(object):
"""docstring for MyQueue"""
def __init__(self, arg):
    super(MyQueue, self).__init__()
    # self.arg = arg
    self._queue = Queue.Queue()
    self._rdfd, self._wrfd = os.pipe()
    return

def enQ(self, item=None, block=True, timeout=None):
    os.write(self._wrfd, '+')
    self._queue.put(item)
    return

def deQ(self, block=True, timeout=None):
    _itm = self._queue.get(block=block, timeout=timeout)
    _msg = os.read(self._rdfd, 1)
    return _itm

def get_notify(self):
    return self._rdfd

---

^{pr2}$