使用proactor的应用如何在退出时避免内存泄漏?

peakzhang

我的应用使用proactor模式,当应用退出时,调用end_event_loop先结束proactor事件处理循环.
然而如果此时有一个未完成的write调用,则会导致内存泄漏.(vc 2003下报告内存泄漏).
我的问题是:
1. 如果取消一个未完成的write调用?
2. 关闭proactor时,如何获取该未完成write调用持有的message block(从而释放其内存)?
谢谢!

peakzhang

尝试调用异步处理对象的cancel()方法，不过未必成功。
我认为，不必关心异步发起产生的所谓“泄露”，无关紧要。因为系统已经停止运行，OS会自动回收。
再者，异步发起的请求，在得到处理的时候，就没有泄露了。

peakzhang

>尝试调用异步处理对象的cancel()方法，不过未必成功。
是什么意思？调用ACE_Asynch_Read_Stream的cancel方法吗？不过未必成功是什么意思？

>不必关心异步发起产生的所谓“泄露”，无关紧要。因为系统已经停止运行，OS会自动回收。

是这样。我是想得到一个完美的解决方案。最好是能够解决该问题。

peakzhang

这是我曾经的一段代码的简化版,应该能很好的解决你的问题：

2. class MY_Handler : public ACE_Service_Handler
3. {
4. public:
5.   MY_Handler(void)
6.     : mblk_ (0)
7.   {}
9.   virtual ~DH_Handler(void)
10.   { this->destroy (); }
12.   // Called by ACE_Asynch_Acceptor when a client connects.
13.   virtual void open (ACE_HANDLE new_handle,
14.                      ACE_Message_Block &message_block)
15.   {
16.    reader_.open (*this, new_handle, 0, proactor ());
17.    writer_.open (*this, new_handle, 0, proactor ());
18.    
19.    ACE_NEW_NORETURN (mblk_,
20.                      ACE_Message_Block (ACE_DEFAULT_CDR_BUFSIZE));
21.    // Align the Message Block for a CDR stream
22.    ACE_CDR::mb_align (mblk_);
23.    reader_.read (*mblk_, 自定义长度);
24.   }
26. protected:
27.   // Handle input from clients.
28.   virtual void handle_read_stream (const ACE_Asynch_Read_Stream::Result &result)
29.   {
30.    if (!result.success () || result.bytes_transferred () == 0)
31.      delete this;
32.    else if (result.bytes_transferred () < result.bytes_to_read ())
33.      reader_.read (*mblk_,
34.                    result.bytes_to_read () - result.bytes_transferred ());
35.    else
36.      writer_.write (*mblk_,
37.                    mblk_.size ());
38.   }
40.   // Handle output to clients.
41.   virtual void  handle_write_stream (const ACE_Asynch_Write_Stream::Result &result)
42.   {
43.    if (!result.success () || result.bytes_transferred () == 0)
44.      delete this;
45.    else
46.    {
47.     mblk_.reset ();
48.     // Align the Message Block for a CDR stream
49.     ACE_CDR::mb_align (mblk_);
50.     reader_.read (*mblk_, 自定义长度);
51.    }
52.   }
54.   // Called by destructor to release all resources. Can be override by sub class.
55.   virtual void destroy (void)
56.   {
57.    reader_.cancel ();
58.    writer_.cancel ();
59.    ACE_OS::closesocket (handle ());
60.    if (mblk_ != 0)
61.      mblk_->release ();
62.    mblk_ = 0;
63.   }
65. protected:
66.   ACE_Message_Block *mblk_;       // Block to received
67.   ACE_Asynch_Read_Stream reader_; // Async read factory
68.   ACE_Asynch_Write_Stream writer_; // Async write factory
69. };

复制代码

这个例子简单的从客户端读取一段数据流然后原封不动的返回给客户端，在对端关闭连接或handler的创建者手动关闭连接的时候，都只需要简单的删除维护该连接的handler就可以，handler自动清理socket句柄和ACE_Message_Block数据块，并cancel异步读写单元。

最后，在主线程结束的时候，你只需要在发起proactor的end_event_loop请求的同时，枚举并删除每个handler对象，然后调用ACE_Thread_Manager的wait等待正在进行中的异步动作的结束，就可以完全安全并无泄漏的终止你的应用。