JAWS3中的Reactor框架

peakzhang

最近开始学习ACE，想把其中的JAWS3部分内容抽取出来，封装成一个动态库，供MFC或者在DELPHI中都可使用。ACE中自带的JAWS3是不完整的，为了了解它的运行流程，就使用JAWS3目录下的子目录small，用vc6在其中新建一个Console类型的工程，然后把所有文件都包含进来，并把JAWS3目录下的main.cpp文件也拷贝过来，

2. int
3. main (int argc, ACE_TCHAR *argv[])
4. {
5.   ACE_REACTOR_INSTANCE_INIT;
7. //以下两行代码是增加的
8.     TeraSS_Acceptor acp;
9.     acp.init(argc, argv);
11.   JAWS_Signal_Task::instance ();
13.   if (ACE_Service_Config::open (argc, argv) == -1
14.       && errno != ENOENT)
15.     ACE_ERROR_RETURN ((LM_ERROR,
16.                        ACE_TEXT ("%p\n"),
17.                        ACE_TEXT ("open")),
18.                       1);
20.   // Run forever, performing the configured services until we
21.   // shutdown.
23.   JAWS_Event_Dispatcher::run_event_loop ();
25.   ACE_Thread_Manager::instance ()->wait ();
27.   return 0;
28. }

复制代码

jaws.conf配置文件中的 JAWS_IO = REACTIVE ，并在SS_State_READ.cpp中的service和transition函数打断点，
这样运行后，程序能够正确进入以上两个函数。

现在让Reactor不在主线程中运行（要应用到MFC中时，它是不可能在主线程中运行的），修改了Event_Dispatcher.cpp
文件，是ACE_Reactor::run_event_loop ()在另一个线程中启动，如下

2. JAWS_Event_Dispatcher_Proactor_Event_Loop (void *)
3. {
4.   ACE_Proactor::run_event_loop ();
5.   return 0;
6. }
8. static ACE_THR_FUNC_RETURN
9. JAWS_Event_Dispatcher_Reactor_Event_Loop (void *)
10. {
11.   //ACE_REACTOR_INSTANCE_INIT;
12.   int result;
13.   result = ACE_Thread::spawn ( JAWS_Event_Dispatcher_Proactor_Event_Loop, 0, THR_BOUND);
14.   if (result < 0)
15.     {
16.       ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Thread::spawn"));
17.       return 0;
18.     }
20.   // Now, enter the reactor's event loop.
21.   ACE_Reactor::run_event_loop ();
23.   // End the proactor's event loop if reactor was interrupted.
24.   ACE_Proactor::end_event_loop ();
25.   
26.   return 0;
27. }
29. void
30. JAWS_Event_Dispatcher::end_event_loop (void)
31. {
32.   ACE_Reactor::end_event_loop ();
33. }
36. void
37. JAWS_Event_Dispatcher::run_event_loop (void)
38. {
39.   // First, initiate the proactor thread
41.   int result;
42.   result = ACE_Thread::spawn (JAWS_Event_Dispatcher_Reactor_Event_Loop, 0, THR_BOUND);
44.   if (result < 0)
45.     {
46.       ACE_ERROR ((LM_ERROR, "%p\n", "ACE_Thread::spawn"));
47.       return;
48.     }
49. }

复制代码

即把原来在JAWS_Event_Dispatcher::run_event_loop中执行的内容放在另一个线程中执行了。这时，再执行程序通讯时，能进service函数，但进不了transition函数。如果修改aws.conf配置文件中的 JAWS_IO 为SYNCH或ASYNCH，则
都能进入，为什么尼？ Reactor框架必须在主线程中执行吗？

peakzhang

ace_reactor::instance()->run_event_loop()之前，加上

ace_reactor::instance()->owner(ace_thread::self());获得reactor的使用权