如何使异步读安全返回?ACE_OS::closesocket(this->handle());
Proactor框架中,使用ACE_Service_Handler当我想析构这个对象时:
~WL_Service_Handler(void)
{
....................
m_reader.cancel();
m_writer.cancel();
ACE_OS::closesocket(this->handle());
handle(ACE_INVALID_HANDLE);
m_bCanWrite = 0;
...............
}
这样当 virtual void handle_read_stream(const ACE_Asynch_Read_Stream::Result &result)返回时,程序就崩溃了.
看到其他一些事例,是在open函数里加入
ACE_Sig_Action no_isgpipe((ACE_SignalHandler) SIG_IGN);
no_isgpipe.register_action(SIGPIPE,0);
说是"禁止SIGPIPE,防止异步写终止程序"
但是如何防止异步读返回,导致程序崩溃啊?最好代码说明一下嘛,初学者,讲个理论可能不明白:handshake 后来就想了另外一个办法,当想析构它时,绝不调用delete this,
而是调用另外一个函数:
void DeleteSelf()
{
ACE_OS::closesocket(this->handle());
handle(ACE_INVALID_HANDLE);
}
virtual void handle_read_stream(const ACE_Asynch_Read_Stream::Result &result)
{
if (!result.success()
|| result.bytes_transferred() == 0)
{
delete this;
}
else
{
......
}
}
~WL_Service_Handler(void)
{
....................
m_reader.cancel();
m_writer.cancel();
m_bCanWrite = 0;
...............
}
这时候,非常诡异的问题就出现了,这个事件处理器居然会从其他事件处理器抢读,
比如本地a,b,c 分别连接到服务器A,B,C,现在我按照上述的办法关闭a(调用DeleteSelf,而不是delete this)
从服务器B,C发回来的数据,居然奇异的被a抢读了,b,c只能读到一部分发回来的数据.
我想要的现实是:短连接,怎么实现呢? 似乎问题出在怎么把这个事件处理器从Proactor里面移除,应该调用哪个函数来进行移除呢? 你还没理解Proactor框架的奥妙。
Proactor框架尤其特别的地方，不仔细思考是很难发现的。
我给你找找 http://www.acejoy.com/bbs/viewthread.php?tid=1126 m_reader.cancel();
m_writer.cancel();
ACE_OS::closesocket(this->handle());
handle(ACE_INVALID_HANDLE);
m_bCanWrite = 0;
上面那些代码封装为一个成员函数 叫做 closeclient();
{
if ( handle() != ACE_INVALID_HANDLE)
{
m_reader.cancel();
m_writer.cancel();
ACE_OS::closesocket(this->handle());
handle(ACE_INVALID_HANDLE);
m_bCanWrite = 0;
}
}
2在delete之前调用 closeclient 和析构函数里面也调用 楼主的用法比较罕见，多线程跑多个proactor实例。。
还有，也不用每个线程一个connector，共用一个就行。
很多人容易把线程和对象搞混。一个是静态的对象一个是动态的执行概念。
个人意见，client端没必要用proactor，异步方式开发成本相对较高，能用清晰的同步方式最好。
页:
[1]