2014-09-28 50 views
0

我有一个类连接是一种Zmq Request/Reply上的包装。使用这个我会接受来自客户端的请求并将回复发送回去。用于实现这两个功能是: -需要一种方法来同步两个操作

void Connection::receiveMessage() 
{ 
//recv messages over zmq and send it to back-end. 
} 

void Connection::sendMessage() 
{ 
//This method would be called by back-end and it will send the message over Zmq. 
} 

问题面临: - 作为ZMQ请求/应答是同步操作,我必须发送应答(我会得到来自后端在响应于recvd消息)在收到新消息之前。在某些情况下,Connection类在后端对象上执行一个方法并返回。当后端准备好数据时,它会调用sendMessage。但在这里我再次尝试接收消息而不发送先前的响应。

任何人都可以请帮助我确保连接不会进入recv,直到它发送回应以前的消息。 在此先感谢。

回答

相关问题