如何正确退出rector ?

peakzhang

mfc ace 5.5

已经能够正确接受数据，单独开了个线程跑ACE_Reactor::instance()->run_reactor_event_loop();

2. UINT ThreadReactor(LPVOID param)
3. {
4.     int result = ACE_Reactor::instance()->run_reactor_event_loop();
5.     return 0;
6. }
8. void CAceTestDlg::OnButServer()
9. {
10.     //*  ACE_WFMO_Reactor 默认方式
11.     ACE_INET_Addr port_listen(9000);
12.     m_ClientAcceptor.reactor(ACE_Reactor::instance());
13.     if(m_ClientAcceptor.open(port_listen) == -1)
14.         return ;
15.     AfxBeginThread(ThreadReactor,NULL);
16. }

复制代码

在dia里执行end_reactor_event_loop(),也可以成功结束上面
ThreadReactor 线程。

2. void CAceTestDlg::OnButtonClose()
3. {
4.     // TODO: Add your control notification handler code here
5.     ACE_Reactor::instance()->end_reactor_event_loop();
6. }

复制代码

问题1 为何ThreadReactor结束后，仍能在客户端Connect ?
问题2 如何正确退出,不引发错误 ?

出错位置

2. ClientAcceptor::~ClientAcceptor()
3. {
4.     reactor()->remove_handler(ACE_INVALID_HANDLE,0);
5. }

复制代码

peakzhang

附注:
      先前代码是因为ClientAcceptor析构在ACE::fini()之后

       修改后,发现 ACE::fini() 依然错误
void CAceTestDlg::OnClose()
{
    // TODO: Add your message handler code here and/or call default
    ACE_Reactor::instance()->owner(ACE_OS::thr_self());
    ACE::fini();
    CDialog::OnClose();

}
不解!

peakzhang

追踪到
    ACE_Framework_Repository::close_singleton ();

发生错误,系内部 delete ACE_Framework_Repository::repository_; 出错

如何解决?

peakzhang

没有正确的进行线程同步，你必须等待ThreadReactor正常退出后，再执行关闭操作。

这类问题是使用ACE经常碰见的问题了。可以用WaitForSingleObject来处理，或者用ACE_Task来处理。

peakzhang

ThreadReactor 的确是正常退出的.
    end_reactor_event_loop 后     run_reactor_event_loop 返回0

peakzhang

不这么认为，你确定那个线程退出了吗？

或者检查其它线程同步代码吧。

peakzhang

哦,确定退出了.

因为是在手工测试,其他地方没有线程同步的地方.

那里可以把代码传上去?

peakzhang

只开了一个线程

2. UINT ThreadReactor(LPVOID param)
3. {
4.     ACE_INET_Addr port_listen(1515);
5.     ClientAcceptor ClientAcceptor;
6.     ClientAcceptor.reactor(ACE_Reactor::instance());
7.     if(ClientAcceptor.open(port_listen) == -1)
8.         return -1;
9.     int result = ACE_Reactor::instance()->run_reactor_event_loop();
10.     return result;
11. }
12. //启动线程
13. void CAceTestDlg::OnButServer()
14. {
15.     AfxBeginThread(ThreadReactor,NULL);
16. }
18. //这里停止
19. void CAceTestDlg::OnButtonClose()
20. {
21.     // TODO: Add your control notification handler code here
22.     ACE_Reactor::instance()->end_reactor_event_loop();
23. }
25. //这里析构，略:在initDialog 里 ACE::init()
26. BOOL CAceTestDlg::DestroyWindow()
27. {
28.     // TODO: Add your specialized code here and/or call the base class
29.     ACE_Reactor::instance()->owner(ACE_OS::thr_self());
30.     ACE::fini();        
31.     return CDialog::DestroyWindow();
32. }
34. //Acceptor 的 handle_close
35. int ClientAcceptor::handle_close(ACE_HANDLE handle,ACE_Reactor_Mask close_mask)
36. {
37.     if( acceptor_.get_handle()  != ACE_INVALID_HANDLE)
38.     {
39.         ACE_Reactor_Mask m = ACE_Event_Handler::ACCEPT_MASK|
40.             ACE_Event_Handler::DONT_CALL;
41.         reactor()->remove_handler(this,m);
42.         acceptor_.close();
43.     }
44.     return 0;
45. }
46. //ClientService的 handle_close
47. int ClientService::handle_close(ACE_HANDLE handle, ACE_Reactor_Mask close_mask)
48. {
49.     if( ACE_Event_Handler::WRITE_MASK == close_mask)
50.         return 0;
51.     close_mask = ACE_Event_Handler::ALL_EVENTS_MASK|ACE_Event_Handler::DONT_CALL;
52.     reactor()->remove_handler(this,close_mask);
53.     sock_.close();
54.     output_queue_.flush();
55.     delete this;
56.     return 0;
57. }

复制代码

注:
    除了开个线程,其他均为抄书.

peakzhang

线程同步处理有问题，

UINT ThreadReactor(LPVOID param)
在你void CAceTestDlg::OnButtonClose()
后，不能保证立刻返回并且退出。同样，ClientService::handle_close也不能，这就是多线程抢占的特性。你必须等待额外的处理线程退出，光debug是没用的，多线程程序和网络程序有某种程度的不可调试性。
不信你在ACE::fini(); 前等待2秒钟试试。Sleep(2000);

peakzhang

To: winston
  
   void CAceTestDlg::OnButtonClose()  这个是mfc 的函数阿。
   作用是响应一个Button事件。
   在这个里面执行 end_reactor_event_loop 后，
   ThreadReactor就结束了

   ACE::fini();是在dia 的OnClose 事件中的，要手工关闭窗口才会执行。
   换而言之，关闭窗口ACE::fini()是在 ThreadReactor n久后的动作。

   Sleep(2000);根本没必要，不过还是测试了一下，呵呵。没有反应