Proactor使用中的问题

peakzhang

我在使用ACE5.5的时候，用到了其中的Proactor。
我的测试程序先创建了win32下的proactor后，在线程中启动了run_event_loop方法，然后在析构的时候调用了end_event_loop方法，可是每次在我调用end_event_loop方法的时候就要抛出一个异常，内容为：
"Unhandled exception in proact.exe(KERNEL32.DLL): 0xE06D7363: Microsoft C++ Exception"。
大家在使用ACE5.5的Proactor时有没有遇到过类似的问题呢？

下面是我的代码，只是简单的创建Proactor在删除它。
//异步反应器框架类

2. class SEA_Proactor : public ACE_Task<ACE_MT_SYNCH>
3. {
4. public :
5. SEA_Proactor():
6.         sem_ ((unsigned int) 0),
7.         proactor_(0){}
8. virtual ~SEA_Proactor()
9. {
10.         (void) this->stop ();//停止异步方应器
11.         this->delete_proactor();//删除已创建的异步反应器
12. }
13.     //启动异步反应器
14. virtual int start(int iThreads)//启动线程的数目)
15. {
16.   //创建一个异步反应器
17.   if(this->create_proactor() == -1)
18.    return -1;
19.         //启动异步方应器线程函数
20.         if(this->activate (THR_JOINABLE | THR_NEW_LWP,iThreads) == -1)
21.    return -1;
22.         //线程池中的每个线程等待获取线程锁
23.         for(;iThreads > 0;iThreads--)
24.   {
25.             if(sem_.acquire() == -1)
26.     return -1;
27.   }
28.         return 0;
29. }
30.     //停止异步方应器
31. virtual int stop(void)
32. {
33.   //停止异步反应器内核运行
34.   if(this->proactor_ != 0)
35.   {
36.     ACE_Proactor::end_event_loop(); //执行到这一句就出错
37.   }
38.   //等待异步反应器线程函数结束
39.   if(this->wait () == -1)
40.       return -1;
41.   return 0;
42. }
43.     //异步方应器线程函数
44. virtual int svc(void)
45. {
46.   //发出解锁信号表示线程函数已经开始运行
47.         sem_.release(1);
48.         //开始异步反应器内核运行
49.         ACE_Proactor::run_event_loop();
50.   return 0;
51. }
52. private:
53. //创建一个异步反应器
54.     int create_proactor(void)
55. {
56.   //定义一个32位windows操作系统下的异步反应器接口类的指针
57.         ACE_WIN32_Proactor *proactor_impl = 0;
58.         //实例化这个指针
59.         ACE_NEW_RETURN (proactor_impl,
60.                         ACE_WIN32_Proactor,
61.                         -1);
62.         //实例化一个ACE的异步反应器类，并和前一个异步反应器接口类绑定
63.         ACE_NEW_RETURN (this->proactor_,
64.                         ACE_Proactor (proactor_impl, 1 ),
65.                         -1);
66.         //将异步反应器单体类的实例指向实例化的ACE异步反应器类
67.         ACE_Proactor::instance (this->proactor_, 1);
68.         return 0;
69. }
70.     //删除已创建的异步反应器
71.     void delete_proactor(void)
72. {
73.   if(this->proactor_ != 0)
74.   {
75.       ACE_Proactor::close_singleton ();
76.             this->proactor_ = 0;
77.   }
78. }
79.     ACE_Thread_Semaphore sem_;//线程池信号
80. ACE_Thread_Semaphore sem1_;//线程池信号
81.     ACE_Proactor * proactor_;//异步反应器实例指针
82. };
83. //main函数测试
84. int ACE_TMAIN(int argc, ACE_TCHAR *argv[])
85. {
86. SEA_Proactor *test;
87. ACE_NEW_RETURN(test, SEA_Proactor, -1);
88. test->start(1);
89. ACE_OS::sleep(1); //只要有这句话(换成scanf,或者弹出一个框,产生一个耽搁的时间)就要出错
90. delete test;   
91. return 0;
92. }

复制代码

peakzhang

代码里面错漏很多。
ACE_Task是不能直接删除的，需要让他停止队列的运作。
virtual int svc(void)
你的停止过程，是在析构函数里面，不推荐，因为析构函数里面运行，常常意味着其它附属资源的释放，比如你的类成员函数已经释放掉了。
(void) this->stop ();//停止异步方应器
this->delete_proactor();//删除已创建的异步反应器
这两句调用，缺乏同步关系，导致task被删除了，svc和Proactor还在跑，肯定报错。

peakzhang

看了版主的回答，我还有以下几个问题：

1。"ACE_Task是不能直接删除的,需要让它停止队列的运作"，我继承自ACE_Task是为了能让Proactor在线程里运行event_loop()，虽然ACE_Task里自带了一个msg_queue，但我并没有对它进行任何操作。斑竹的意思是让我加一句"this->msg_queue()->deactivate()"？

2。(void) this->stop ();//停止异步方应器
this->delete_proactor();//删除已创建的异步反应器
斑竹说上面这两句的调用缺乏同步关系，但我的问题是：每次调试只要到了end_event_loop()方法的时候就出错，我可以不把这些停止操作放在delete里面，可以在main函数里调用，但同样的，遇到end_event_loop时就要出错。我在end_event_loop调用之前需要做点什么其他的么？ACE提供给我们的就是一句end_event_loop。

peakzhang

//定义一个32位windows操作系统下的异步反应器接口类的指针
        ACE_WIN32_Proactor *proactor_impl = 0;
        //实例化这个指针
        ACE_NEW_RETURN (proactor_impl,
                        ACE_WIN32_Proactor,
                        -1);
        //实例化一个ACE的异步反应器类，并和前一个异步反应器接口类绑定
        ACE_NEW_RETURN (this->proactor_,
                        ACE_Proactor (proactor_impl, 1 ),
                        -1);
        //将异步反应器单体类的实例指向实例化的ACE异步反应器类
        ACE_Proactor::instance (this->proactor_, 1);
---------------------------------------------------------

上面代码全部可以不要，改成：
this->proactor_ = ACE_Proactor::instance();
因为Windows平台，默认的初始化对象就是ACE_WIN32_Proactor.
故障消除，出错的地方在：
int
ACE_WIN32_Asynch_Result::post_completion (ACE_Proactor_Impl *proactor)
{
  // Get to the platform specific implementation.
  ACE_WIN32_Proactor *win32_proactor = dynamic_cast<ACE_WIN32_Proactor *> (proactor);

  if (win32_proactor == 0)
    ACE_ERROR_RETURN ((LM_ERROR,
                       ACE_LIB_TEXT ("Dynamic cast to WIN32 Proactor failed\n")),
                      -1);

  // Post myself.
  return win32_proactor->post_completion (this);
}
你初始化的代码有问题，导致Proactor实际运行的，和你结束的不是一个对象，应该是这个问题。

ACE_Task的结束，需要等待svc结束，svc是另外的线程开启的，所以一般会wait()一下。
你的代码很危险，因为删除的对象和运行的线程之间没有同步关系，极其容易因为崩溃错误。