1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
<HTML>
<HEAD>
<META HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=iso-8859-1">
<META NAME="GENERATOR" CONTENT="Mozilla/4.04 [en] (X11; I; Linux 2.0.32 i486) [Netscape]">
<META NAME="Author" CONTENT="James CE Johnson">
<META NAME="Description" CONTENT="A first step towards using ACE productively">
<TITLE>ACE Tutorial 007</TITLE>
</HEAD>
<BODY TEXT="#000000" BGCOLOR="#FFFFFF" LINK="#000FFF" VLINK="#FF0F0F">
<CENTER><B><FONT SIZE=+2>ACE Tutorial 007</FONT></B></CENTER>
<CENTER><B><FONT SIZE=+2>Creating a thread-pool server</FONT></B></CENTER>
<P>
<HR WIDTH="100%">
<P>Something new this time is <A HREF="client_acceptor.cpp">client_acceptor.cpp</A>.
I finally had enough code to move it out of the header.
<P>
<HR WIDTH="100%">
<BR><FONT FACE="Arial,Helvetica">// $Id: client_acceptor.cpp,v 1.1 1998/08/30
16:04:11 jcej Exp $</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">#include "client_acceptor.h"</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">/*</FONT>
<BR><FONT FACE="Arial,Helvetica"> Construct ourselves with
the chosen concurrency strategy. Notice that we also</FONT>
<BR><FONT FACE="Arial,Helvetica"> set our Thread_Pool reference
to our private instance.</FONT>
<BR><FONT FACE="Arial,Helvetica"> */</FONT>
<BR><FONT FACE="Arial,Helvetica">Client_Acceptor::Client_Acceptor( int
_concurrency )</FONT>
<BR><FONT FACE="Arial,Helvetica"> : concurrency_(_concurrency)</FONT>
<BR><FONT FACE="Arial,Helvetica"> ,the_thread_pool_(private_thread_pool_)</FONT>
<BR><FONT FACE="Arial,Helvetica">{</FONT>
<BR><FONT FACE="Arial,Helvetica">}</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">/*</FONT>
<BR><FONT FACE="Arial,Helvetica"> Construct ourselves with
a reference to somebody else' Thread_Pool. Obvioulsy</FONT>
<BR><FONT FACE="Arial,Helvetica"> our concurrency strategy
is "thread_pool_" at this point.</FONT>
<BR><FONT FACE="Arial,Helvetica"> */</FONT>
<BR><FONT FACE="Arial,Helvetica">Client_Acceptor::Client_Acceptor( Thread_Pool
& _thread_pool )</FONT>
<BR><FONT FACE="Arial,Helvetica"> : concurrency_(thread_pool_)</FONT>
<BR><FONT FACE="Arial,Helvetica"> ,the_thread_pool_(_thread_pool)</FONT>
<BR><FONT FACE="Arial,Helvetica">{</FONT>
<BR><FONT FACE="Arial,Helvetica">}</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">/*</FONT>
<BR><FONT FACE="Arial,Helvetica"> When we're destructed, we
may need to cleanup after ourselves. If we're running</FONT>
<BR><FONT FACE="Arial,Helvetica"> with a thread pool that we
own, it is up to us to close it down.</FONT>
<BR><FONT FACE="Arial,Helvetica"> */</FONT>
<BR><FONT FACE="Arial,Helvetica">Client_Acceptor::~Client_Acceptor( void
)</FONT>
<BR><FONT FACE="Arial,Helvetica">{</FONT>
<BR><FONT FACE="Arial,Helvetica">
if( this->concurrency() == thread_pool_ && thread_pool_is_private()
)</FONT>
<BR><FONT FACE="Arial,Helvetica">
{</FONT>
<BR><FONT FACE="Arial,Helvetica">
thread_pool()->close();</FONT>
<BR><FONT FACE="Arial,Helvetica">
}</FONT>
<BR><FONT FACE="Arial,Helvetica">}</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">/*</FONT>
<BR><FONT FACE="Arial,Helvetica"> Similar to the destructor
(and close() below) it is necessary for us to open the</FONT>
<BR><FONT FACE="Arial,Helvetica"> thread pool in some circumstances.</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica"> Notice how we delegate most
of the open() work to the open() method of our baseclass.</FONT>
<BR><FONT FACE="Arial,Helvetica"> */</FONT>
<BR><FONT FACE="Arial,Helvetica">int Client_Acceptor::open( const ACE_INET_Addr
& _addr, ACE_Reactor * _reactor, int _pool_size )</FONT>
<BR><FONT FACE="Arial,Helvetica">{</FONT>
<BR><FONT FACE="Arial,Helvetica">
if( this->concurrency() == thread_pool_ && thread_pool_is_private()
)</FONT>
<BR><FONT FACE="Arial,Helvetica">
{</FONT>
<BR><FONT FACE="Arial,Helvetica">
thread_pool()->open(_pool_size);</FONT>
<BR><FONT FACE="Arial,Helvetica">
}</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">
return inherited::open(_addr,_reactor);</FONT>
<BR><FONT FACE="Arial,Helvetica">}</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">/*</FONT>
<BR><FONT FACE="Arial,Helvetica"> Here again we find that we
have to manage the thread pool. Like open() we also delegate</FONT>
<BR><FONT FACE="Arial,Helvetica"> the other work to our baseclass.</FONT>
<BR><FONT FACE="Arial,Helvetica"> */</FONT>
<BR><FONT FACE="Arial,Helvetica">int Client_Acceptor::close(void)</FONT>
<BR><FONT FACE="Arial,Helvetica">{</FONT>
<BR><FONT FACE="Arial,Helvetica">
if( this->concurrency() == thread_pool_ && thread_pool_is_private()
)</FONT>
<BR><FONT FACE="Arial,Helvetica">
{</FONT>
<BR><FONT FACE="Arial,Helvetica">
thread_pool()->close();</FONT>
<BR><FONT FACE="Arial,Helvetica">
}</FONT><FONT FACE="Arial,Helvetica"></FONT>
<P><FONT FACE="Arial,Helvetica">
return inherited::close();</FONT>
<BR><FONT FACE="Arial,Helvetica">}</FONT>
<BR><FONT FACE="Arial,Helvetica"></FONT> <FONT FACE="Arial,Helvetica"></FONT>
<P>
<HR WIDTH="100%">
<P>Nothing really surprising here. Most of it just manages the Thread_Pool.
<P>
<HR WIDTH="100%">
<CENTER>[<A HREF="..">Tutorial Index</A>] [<A HREF="page05.html">Continue
This Tutorial</A>]</CENTER>
</BODY>
</HTML>
|
