关于JAWS的一些问题

laja

最近看了一下JAWS的代码,thread_per_request模式下：

2. ...
3.   for (;;)
4.     {
5.       if (this->acceptor_.accept (stream) == -1)
6.         ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
7.                            ACE_TEXT ("HTTP_Acceptor::accept")), -1);
9.       Thread_Per_Request_Task *t;
10.       // Pass grp_id as a constructor param instead of into open.
11.       ACE_NEW_RETURN (t, Thread_Per_Request_Task (stream.get_handle (),
12.                                                   this->tm_,
13.                                                   grp_id,
14.                                                   factory),
15.                       -1);
18.       if (t->open () != 0)
19.         ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"),
20.                            ACE_TEXT ("Thread_Per_Request_Task::open")),
21.                           -1);
23.       // Throttling is not allowing too many threads to run away.
24.       // Should really use some sort of condition variable here.
25.       if (!this->throttle_)
26.         continue;
28.       // This works because each task has only one thread.
29.       while (this->tm_.num_tasks_in_group (grp_id) > this->threads_)
30.         this->tm_.wait (&wait_time);
31.     }
32.     ...

复制代码

这种方式在多个并发请求的时候是否会丢失？


还有Synch_Thread_Pool_Task模式下：

2. ...
3.   for (;;)
4.     {
5.       ACE_SOCK_Stream stream;
6.       // Lock in this accept.  When it returns, we have a connection.
7.       if (this->acceptor_.accept (stream) == -1)        /// 这里其中第一个线程会等待accept，其余的等待锁，直到一个新的连接到来
8.         ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT("%p\n"),
9.                            ACE_TEXT ("HTTP_Acceptor::accept")), -1);
11.       ACE_Message_Block *mb = 0;                                       
12.       ACE_NEW_RETURN (mb,  ACE_Message_Block (HTTP_Handler::MAX_REQUEST_SIZE + 1), -1);       
14.       // Create an HTTP Handler to handle this request
15.       HTTP_Handler *handler = this->factory_.create_http_handler ();
16.       handler->open (stream.get_handle (), *mb);
18.       // Handler is destroyed when the I/O puts the Handler into the
19.       // done state.
20.       mb->release ();
21.       ACE_DEBUG ((LM_DEBUG,ACE_TEXT (" (%t) in Synch_Thread_Pool_Task::svc, recycling\n")));
22.     }
23. ...

复制代码

这边以线程池模式存在，而处理一个新连接时会为每个连接创建Handler，这里如果使用一个Handler Pool效果会不会更好些？

laja

后来经测试发现Reactor 模式 也会在并发连接的情况下，连接丢失，请问有谁知道怎么避免或改进这个问题吗？