blob: 9e19072594233dd545279b533391d378a320e3f1 (
plain)
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
|
<!-- $Id$ -->
<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>
<HR>
<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%">
<PRE>
<font color=red>// $Id$</font>
<font color=blue>#include</font> "<font color=green>client_acceptor.h</font>"
<font color=red>/* Construct ourselves with the chosen concurrency strategy. Notice
that we also set our Thread_Pool reference to our private instance. */</font>
<font color=#008888>Client_Acceptor::Client_Acceptor</font> (int concurrency)
: concurrency_ (concurrency),
the_thread_pool_ (private_thread_pool_)
{
}
<font color=red>/* Construct ourselves with a reference to somebody else' Thread_Pool.
Obvioulsy our concurrency strategy is "<font color=green>thread_pool_</font>" at this point. */</font>
<font color=#008888>Client_Acceptor::Client_Acceptor</font> (Thread_Pool &thread_pool)
: concurrency_ (thread_pool_),
the_thread_pool_ (thread_pool)
{
}
<font color=red>/* When we're destructed, we may need to cleanup after ourselves. If
we're running with a thread pool that we own, it is up to us to
close it down. */</font>
<font color=#008888>Client_Acceptor::~Client_Acceptor</font> (void)
{
if (this->concurrency() == thread_pool_ && thread_pool_is_private ())
thread_pool ()->close ();
}
<font color=red>/* Similar to the destructor (and close() below) it is necessary for
us to open the thread pool in some circumstances.
Notice how we delegate most of the open() work to the open() method
of our baseclass. */</font>
int
<font color=#008888>Client_Acceptor::open</font> (const ACE_INET_Addr &addr,
ACE_Reactor *reactor,
int pool_size)
{
if (this->concurrency() == thread_pool_ && thread_pool_is_private ())
thread_pool ()->start (pool_size);
return <font color=#008888>inherited::open</font> (addr, reactor);
}
<font color=red>/* Here again we find that we have to manage the thread pool. Like
open() we also delegate the other work to our baseclass. */</font>
int
<font color=#008888>Client_Acceptor::close</font> (void)
{
if (this->concurrency() == thread_pool_ && thread_pool_is_private ())
thread_pool ()->stop ();
return <font color=#008888>inherited::close</font> ();
}
</PRE>
<HR WIDTH="100%">
<P>Nothing really surprising here. Most of it just manages the Thread_Pool.
<P>
<P><HR WIDTH="100%">
<CENTER>[<A HREF="../online-tutorials.html">Tutorial Index</A>] [<A HREF="page05.html">Continue This Tutorial</A>]</CENTER>
|
