关于Proactor使用Handler池内存泄露的问题

freeeyes

这里确实需要修改一下ACE的源代码。
给ACE_Asynch_Read_Stream增加两个接口。把原来的

1. int
2. ACE_Asynch_Read_Stream:open (ACE_Handler &handler,
3.                               ACE_HANDLE handle,
4.                               const void *completion_key,
5.                               ACE_Proactor *proactor)
6. {
7.   // Get a proactor for/from the user.
8.   proactor = this->get_proactor (proactor, handler);
10.   // Now let us get the implementation initialized.
11.   if ((this->implementation_ = proactor->create_asynch_read_stream ()) == 0)
12.     return -1;
14.   // Call the <open> method of the base class.
15.   return ACE_Asynch_Operation:open (handler,
16.                                      handle,
17.                                      completion_key,
18.                                      proactor);
19. }
20. 拆分成两个新的函数
21. int
22. ACE_Asynch_Read_Stream::Create(ACE_Handler &handler,
23.                               ACE_HANDLE handle,
24.                               ACE_Proactor *proactor)
25. {
26.   proactor = this->get_proactor (proactor, handler);
28.   // Now let us get the implementation initialized.
29.   if ((this->implementation_ = proactor->create_asynch_read_stream ()) == 0)
30.     return -1;
32.   return 0;
34. }
37. int
38. ACE_Asynch_Read_Stream::Bind(ACE_Handler &handler,
39.                               ACE_HANDLE handle,
40.                               const void *completion_key,
41.                               ACE_Proactor *proactor)
42. {
43.   // Call the <open> method of the base class.
44.   return ACE_Asynch_Operation:open (handler,
45.                                      handle,
46.                                      completion_key,
47.                                      proactor);
49. }

复制代码

修改了一下ACE的源码，ACE_Asynch_Read_Stream和ACE_Asynch_Write_Stream对象，修改后，在高并发下CPU使用率明显降低。不过不能要求每个使用者都要重新改写一下ACE的代码吧。。。
既然ACE的Proactor提供了make_handler()方法，就是说明鼓励你使用自己的handler池，但是，这里却留下了一个陷阱。正在下载5.8看看有没有变化,modern在不，有QQ没？呵呵，加我一个吧。

winston

我抽空给代码维护者发信说明一下。这个的确是问题。

freeeyes

http://blog.vckbase.com/bastet/archive/2005/08/26/11540.html

freeeyes

http://blog.vckbase.com/bastet/archive/2005/08/26/11540.html

freeeyes

七猫解决了，他的方法是重载了这个对象，我按照这个方法改，已经没有问题了。

dwh0403

如winston所讲，还是给ACE user发封信去在代码中去彻底解决这个问题