a00638.html

来自「opendds 1.2 最新版 面向分布式实时网络编程」· HTML 代码 · 共 462 行 · 第 1/2 页

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1">
<title>OpenDDS: OpenDDS::DCPS::QueueTaskBase&lt; T &gt; Class Template Reference</title>
<link href="doxygen.css" rel="stylesheet" type="text/css">
<link href="tabs.css" rel="stylesheet" type="text/css">
</head><body>
<!-- Generated by Doxygen 1.4.7 -->
<div class="tabs">
  <ul>
    <li><a href="index.html"><span>Main&nbsp;Page</span></a></li>
    <li><a href="namespaces.html"><span>Namespaces</span></a></li>
    <li id="current"><a href="classes.html"><span>Classes</span></a></li>
    <li><a href="files.html"><span>Files</span></a></li>
    <li><a href="dirs.html"><span>Directories</span></a></li>
    <li><a href="pages.html"><span>Related&nbsp;Pages</span></a></li>
    <li>
      <form action="search.php" method="get">
        <table cellspacing="0" cellpadding="0" border="0">
          <tr>
            <td><label>&nbsp;<u>S</u>earch&nbsp;for&nbsp;</label></td>
            <td><input type="text" name="query" value="" size="20" accesskey="s"/></td>
          </tr>
        </table>
      </form>
    </li>
  </ul></div>
<div class="tabs">
  <ul>
    <li><a href="classes.html"><span>Alphabetical&nbsp;List</span></a></li>
    <li><a href="annotated.html"><span>Class&nbsp;List</span></a></li>
    <li><a href="hierarchy.html"><span>Class&nbsp;Hierarchy</span></a></li>
    <li><a href="functions.html"><span>Class&nbsp;Members</span></a></li>
  </ul></div>
<div class="nav">
<a class="el" href="a01301.html">OpenDDS</a>::<a class="el" href="a01275.html">DCPS</a>::<a class="el" href="a00638.html">QueueTaskBase</a></div>
<h1>OpenDDS::DCPS::QueueTaskBase&lt; T &gt; Class Template Reference</h1><!-- doxytag: class="OpenDDS::DCPS::QueueTaskBase" --><!-- doxytag: inherits="ACE_Task_Base" -->A simple ACE task that manages a queue of request.  
<a href="#_details">More...</a>
<p>
<code>#include &lt;QueueTaskBase_T.h&gt;</code>
<p>
Inheritance diagram for OpenDDS::DCPS::QueueTaskBase&lt; T &gt;:<p><center><img src="a02805.png" border="0" usemap="#a02806" alt="Inheritance graph"></center>
<map name="a02806">
<area href="a00494.html" shape="rect" coords="587,6,1160,30" alt="">
<area href="a00685.html" shape="rect" coords="505,54,1241,78" alt="">
<area href="a00466.html" shape="rect" coords="5,30,128,54" alt="">
</map>
<center><font size="2">[<a href="graph_legend.html">legend</a>]</font></center>Collaboration diagram for OpenDDS::DCPS::QueueTaskBase&lt; T &gt;:<p><center><img src="a02807.png" border="0" usemap="#a02808" alt="Collaboration graph"></center>
<map name="a02808">
<area href="a00466.html" shape="rect" coords="83,7,205,31" alt="">
</map>
<center><font size="2">[<a href="graph_legend.html">legend</a>]</font></center><a href="a00081.html">List of all members.</a><table border="0" cellpadding="0" cellspacing="0">
<tr><td></td></tr>
<tr><td colspan="2"><br><h2>Public Member Functions</h2></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#d824d568546d754d928063c7c0940b20">QueueTaskBase</a> ()</td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Constructor.  <a href="#d824d568546d754d928063c7c0940b20"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">virtual&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#2eb31fd0cee81f95e898be28fd33c00f">~QueueTaskBase</a> ()</td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Virtual Destructor.  <a href="#2eb31fd0cee81f95e898be28fd33c00f"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">int&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#ac1d9285320ccc7f01a6cc4e930be861">add</a> (T &amp;req)</td></tr>

<tr><td class="memItemLeft" nowrap align="right" valign="top">virtual int&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#a114fb1996d739228a0015f4eb243b62">open</a> (void *=0)</td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Activate the worker threads.  <a href="#a114fb1996d739228a0015f4eb243b62"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">virtual int&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#fe637e3d7435e03083fa048a5aae50cc">svc</a> ()</td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">The "mainline" executed by the worker thread.  <a href="#fe637e3d7435e03083fa048a5aae50cc"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">virtual int&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#03b6ab30e5986b7983e9923dbf84aba8">close</a> (u_long flag=0)</td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Called when the thread exits.  <a href="#03b6ab30e5986b7983e9923dbf84aba8"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">virtual void&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#5d76d9c63b34b8c7dcb3108114494363">execute</a> (T &amp;req)=0</td></tr>

<tr><td colspan="2"><br><h2>Private Types</h2></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">typedef ACE_SYNCH_MUTEX&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a></td></tr>

<tr><td class="memItemLeft" nowrap align="right" valign="top">typedef ACE_Guard&lt; <a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a> &gt;&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#427e08ad4ebd8ad56695559022922b4b">GuardType</a></td></tr>

<tr><td class="memItemLeft" nowrap align="right" valign="top">typedef ACE_Condition&lt; <a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a> &gt;&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#60c8633beefeb0a937861438363b2806">ConditionType</a></td></tr>

<tr><td class="memItemLeft" nowrap align="right" valign="top">typedef ACE_Unbounded_Queue&lt;<br>
 T &gt;&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#9d91448bc0a4e0943a35e78af0b7becf">Queue</a></td></tr>

<tr><td colspan="2"><br><h2>Private Attributes</h2></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top"><a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a>&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#17a9b46e5eec029d8d19bc1a16aa243b">lock_</a></td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Lock to protect the "state" (all of the data members) of this object.  <a href="#17a9b46e5eec029d8d19bc1a16aa243b"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top"><a class="el" href="a00638.html#9d91448bc0a4e0943a35e78af0b7becf">Queue</a>&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#fb1fa1eb193299b9084f905841a561fd">queue_</a></td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">The request queue.  <a href="#fb1fa1eb193299b9084f905841a561fd"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top"><a class="el" href="a00638.html#60c8633beefeb0a937861438363b2806">ConditionType</a>&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#f0d03557a7e02a723f20ffd60587aa28">work_available_</a></td></tr>

<tr><td class="memItemLeft" nowrap align="right" valign="top">bool&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#01378176194f000cc28dd6b7aecbe038">shutdown_initiated_</a></td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Flag used to initiate a shutdown request to all worker threads.  <a href="#01378176194f000cc28dd6b7aecbe038"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">bool&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#e5115f36588ba0c8d19362cf40a6d60b">opened_</a></td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">Flag used to avoid multiple <a class="el" href="a00638.html#a114fb1996d739228a0015f4eb243b62">open()</a> calls.  <a href="#e5115f36588ba0c8d19362cf40a6d60b"></a><br></td></tr>
<tr><td class="memItemLeft" nowrap align="right" valign="top">ACE_thread_t&nbsp;</td><td class="memItemRight" valign="bottom"><a class="el" href="a00638.html#6669cb0393296fc1b6140e53336fa354">thr_id_</a></td></tr>

<tr><td class="mdescLeft">&nbsp;</td><td class="mdescRight">The id of the thread created by this task.  <a href="#6669cb0393296fc1b6140e53336fa354"></a><br></td></tr>
</table>
<hr><a name="_details"></a><h2>Detailed Description</h2>
<h3>template&lt;typename T&gt;<br>
 class OpenDDS::DCPS::QueueTaskBase&lt; T &gt;</h3>

A simple ACE task that manages a queue of request. 
<p>
<hr><h2>Member Typedef Documentation</h2>
<a class="anchor" name="60c8633beefeb0a937861438363b2806"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::ConditionType" ref="60c8633beefeb0a937861438363b2806" args="" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>
          <td class="memname">typedef ACE_Condition&lt;<a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a>&gt; <a class="el" href="a00638.html">OpenDDS::DCPS::QueueTaskBase</a>&lt; T &gt;::<a class="el" href="a00638.html#60c8633beefeb0a937861438363b2806">ConditionType</a><code> [private]</code>          </td>
        </tr>
      </table>
</div>
<div class="memdoc">

<p>

</div>
</div><p>
<a class="anchor" name="427e08ad4ebd8ad56695559022922b4b"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::GuardType" ref="427e08ad4ebd8ad56695559022922b4b" args="" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>
          <td class="memname">typedef ACE_Guard&lt;<a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a>&gt; <a class="el" href="a00638.html">OpenDDS::DCPS::QueueTaskBase</a>&lt; T &gt;::<a class="el" href="a00638.html#427e08ad4ebd8ad56695559022922b4b">GuardType</a><code> [private]</code>          </td>
        </tr>
      </table>
</div>
<div class="memdoc">

<p>

</div>
</div><p>
<a class="anchor" name="84589a672fa0699cb7bc71beb6366a34"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::LockType" ref="84589a672fa0699cb7bc71beb6366a34" args="" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>
          <td class="memname">typedef ACE_SYNCH_MUTEX <a class="el" href="a00638.html">OpenDDS::DCPS::QueueTaskBase</a>&lt; T &gt;::<a class="el" href="a00638.html#84589a672fa0699cb7bc71beb6366a34">LockType</a><code> [private]</code>          </td>
        </tr>
      </table>
</div>
<div class="memdoc">

<p>

</div>
</div><p>
<a class="anchor" name="9d91448bc0a4e0943a35e78af0b7becf"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::Queue" ref="9d91448bc0a4e0943a35e78af0b7becf" args="" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>
          <td class="memname">typedef ACE_Unbounded_Queue&lt;T&gt; <a class="el" href="a00638.html">OpenDDS::DCPS::QueueTaskBase</a>&lt; T &gt;::<a class="el" href="a00638.html#9d91448bc0a4e0943a35e78af0b7becf">Queue</a><code> [private]</code>          </td>
        </tr>
      </table>
</div>
<div class="memdoc">

<p>

</div>
</div><p>
<hr><h2>Constructor &amp; Destructor Documentation</h2>
<a class="anchor" name="d824d568546d754d928063c7c0940b20"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::QueueTaskBase" ref="d824d568546d754d928063c7c0940b20" args="()" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>
          <td class="memname"><a class="el" href="a00638.html">OpenDDS::DCPS::QueueTaskBase</a>&lt; T &gt;::<a class="el" href="a00638.html">QueueTaskBase</a>           </td>
          <td>(</td>
          <td class="paramname">          </td>
          <td>&nbsp;)&nbsp;</td>
          <td width="100%"><code> [inline]</code></td>
        </tr>
      </table>
</div>
<div class="memdoc">

<p>
Constructor. 
<p>

</div>
</div><p>
<a class="anchor" name="2eb31fd0cee81f95e898be28fd33c00f"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::~QueueTaskBase" ref="2eb31fd0cee81f95e898be28fd33c00f" args="()" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>
          <td class="memname">virtual <a class="el" href="a00638.html">OpenDDS::DCPS::QueueTaskBase</a>&lt; T &gt;::~<a class="el" href="a00638.html">QueueTaskBase</a>           </td>
          <td>(</td>
          <td class="paramname">          </td>
          <td>&nbsp;)&nbsp;</td>
          <td width="100%"><code> [inline, virtual]</code></td>
        </tr>
      </table>
</div>
<div class="memdoc">

<p>
Virtual Destructor. 
<p>

</div>
</div><p>
<hr><h2>Member Function Documentation</h2>
<a class="anchor" name="ac1d9285320ccc7f01a6cc4e930be861"></a><!-- doxytag: member="OpenDDS::DCPS::QueueTaskBase::add" ref="ac1d9285320ccc7f01a6cc4e930be861" args="(T &amp;req)" -->
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename T&gt; </div>
      <table class="memname">
        <tr>