Linux下如何在多线程中使用Reactor？

peakzhang

下面的代码，编译成可执行程序，可以以带参数和不带参数方式运行，不带参数运行时程序在主线程中监听3000端口
并执行Reactor事件循环，带参数（任意参数均可）运行时程序启动一个线程，在线程中监听3000端口并执行Reactor
事件循环。我遇到的问题是在Linux平台下以带参数方式运行程序，Reactor事件驱动不起来，接受连接和收到数据时都没有回调
相应的函数。而在Windows平台下则一切正常。这是为什么呢？该怎么解决？

1. #include "ace/OS.h"
2. #include "ace/Thread_Manager.h"
3. #include "ace/Reactor.h"
4. #include "ace/SOCK_Connector.h"
5. #include "ace/SOCK_Acceptor.h"
6. #include "ace/Auto_Ptr.h"
7. #include "ace/Log_Msg.h"
10. class ClientService : public ACE_Event_Handler
11. {
12. public:
13. ACE_SOCK_Stream &peer(void)
14. {
15.   return this->sock_;
16. } int open(void)
17. {
18.   return this->reactor()->register_handler(this, ACE_Event_Handler::READ_MASK);
19. } virtual ACE_HANDLE get_handle(void) const
20. {
21.   return this->sock_.get_handle();
22. } virtual int handle_input(ACE_HANDLE fd)
23. {
24.   // 一个简单的EchoServer，将客户端的信息返回    int rev = peer().recv(buf, 100);
25.   if (rev <= 0)
26.    return -1;  ACE_DEBUG((LM_DEBUG, ACE_TEXT("receive data\n")));  peer().send(buf, rev);  return 0;
27. } // 释放相应资源 virtual int handle_close(ACE_HANDLE, ACE_Reactor_Mask mask)
28. {
29.   if (mask == ACE_Event_Handler::WRITE_MASK)
30.    return 0;  mask = ACE_Event_Handler::ALL_EVENTS_MASK |
31.    ACE_Event_Handler::DONT_CALL;
32.   this->reactor()->remove_handler (this, mask);  this->sock_.close();  delete this;  ACE_DEBUG((LM_DEBUG, ACE_TEXT("connection closed\n")));  return 0;
33. }protected:
34. char buf[100];
35. ACE_SOCK_Stream sock_;
36. };class ClientAcceptor : public ACE_Event_Handler
37. {
38. public:
39. virtual ~ClientAcceptor()
40. {
41.   this->handle_close (ACE_INVALID_HANDLE, 0);
42. } int open(const ACE_INET_Addr &listen_addr)
43. {
44.   if (this->acceptor_.open(listen_addr, 1) == -1)
45.   {
46.    ACE_OS::printf("open port fail");
47.    return -1;
48.   }  // 注册接受连接回调事件    return this->reactor()->register_handler(this, ACE_Event_Handler::ACCEPT_MASK);
49. } virtual ACE_HANDLE get_handle(void) const
50. {
51.   return this->acceptor_.get_handle();
52. } virtual int handle_input(ACE_HANDLE fd )
53. {
54.   ClientService *client = new ClientService();
55.   auto_ptr<ClientService> p(client);  if (this->acceptor_.accept(client->peer()) == -1)
56.   {
57.    ACE_DEBUG((LM_DEBUG, ACE_TEXT("accept client fail")));
58.    return -1;
59.   }
60.   ACE_DEBUG((LM_DEBUG, ACE_TEXT("aceept a client\n")));  p.release();
61.   client->reactor(this->reactor());
62.   if (client->open() == -1)
63.    client->handle_close (ACE_INVALID_HANDLE, 0);  return 0;
64. } virtual int handle_close(ACE_HANDLE handle,
65.   ACE_Reactor_Mask close_mask)
66. {
67.   if (this->acceptor_.get_handle() != ACE_INVALID_HANDLE)
68.   {
69.    ACE_Reactor_Mask m = ACE_Event_Handler::ACCEPT_MASK |
70.     ACE_Event_Handler::DONT_CALL;
71.    this->reactor()->remove_handler(this, m);
72.    this->acceptor_.close();
73.   }
74.   return 0;
75. }protected:
76. ACE_SOCK_Acceptor acceptor_;
77. };ACE_THR_FUNC_RETURN event_loop(void* pPara)
78. {
79. ACE_DEBUG((LM_DEBUG, ACE_TEXT("event_loop\n"))); ACE_INET_Addr addr(3000);
80. ClientAcceptor server;
81. server.reactor(ACE_Reactor::instance());
82. server.open(addr);
83. ACE_DEBUG((LM_DEBUG, ACE_TEXT("listen on port : 3000\n"))); while(true)
84. {
85.   ACE_Reactor::instance()->handle_events();
86. }
87. }int main(int argc, char *argv[])
88. {
89. if (argc == 1)
90. {
91.   ACE_INET_Addr addr(3000);
92.   ClientAcceptor server;
93.   server.reactor(ACE_Reactor::instance());
94.   server.open(addr);
95.   ACE_DEBUG((LM_DEBUG, ACE_TEXT("listen on port : 3000\n")));  while(true)
96.   {
97.    ACE_Reactor::instance()->handle_events();
98.   }
99. }
100. else
101. {
102.   ACE_Thread_Manager::instance()->spawn_n(1, event_loop, ACE_Reactor::instance());
103. } ACE_Thread_Manager::instance()->wait(); return 0;
104. }

复制代码

peakzhang

event_loop
reactor->owner(ACE_OS::thr_self());

peakzhang

能说明一下收不到回调事件的原因吗？

以及加reactor->owner(ACE_OS::thr_self());的原因？在linux下，缺省使用ACE_Select_Reactor, 问题是

其owner_成员变量有什么作用？

peakzhang

APG里面记得有说明的。是因为工作模型的原因，领导者/跟随者，领导者需要设置这个。

holyn2002

我刚好在做服务器移植时遇到这个问题，也是在Windows平台下正常，在Linux平台下注册的Acceptor的handle_input不会被调用，在google上搜到了这篇文章，但是看了还是不怎么理解，谁能给解释下，并给出一个解决方法吗？非常感谢！