_thread_chain_8h-source.html

用vc++写的一个简单的线程池的代码

<a name="l00120"></a>00120                 <span class="comment">//threadId = GetCurrentThreadId();</span>
<a name="l00121"></a>00121                 printf(<span class="stringliteral">"In HandleRequest of thread=%d\n"</span>,<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#c70c7a3540e9cdad3e7eac570df96315">threadId</a>);
<a name="l00122"></a>00122 
<a name="l00124"></a>00124                 <span class="keywordflow">while</span>(!<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#5f2473093f1e10d70996f855887a94a0">deleteMe</a>) 
<a name="l00125"></a>00125                 {
<a name="l00126"></a>00126                         WaitForSingleObject(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#e042b57366986410ca9b29a216f868fb">g_Event</a>,INFINITE);
<a name="l00127"></a>00127 
<a name="l00129"></a>00129                         WaitForSingleObject(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#fe31064961fda989ca508ed4cd14294e">threadChkMutex</a>,INFINITE);
<a name="l00130"></a>00130                         {
<a name="l00131"></a>00131                                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#37253f8bdfe3899c4fe09602008b41fb">starttime</a> = GetTickCount();
<a name="l00132"></a>00132                                 ReleaseMutex(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#fe31064961fda989ca508ed4cd14294e">threadChkMutex</a> );
<a name="l00133"></a>00133                         }
<a name="l00134"></a>00134 
<a name="l00136"></a>00136                         <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#7161bcf0e1166fbd59a86f303cb407a5">busy</a>=<span class="keyword">true</span>;
<a name="l00137"></a>00137                         <span class="comment">//printf("Thread %d is busy\n",threadId);</span>
<a name="l00138"></a>00138 
<a name="l00139"></a>00139 
<a name="l00141"></a>00141 
<a name="l00144"></a>00144 
<a name="l00145"></a>00145                         <a class="code" href="class_plugin_thread_pool_1_1_command.html">Command&lt;T&gt;</a>* temp  = <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#3dfa3c57d56981eae59af9acbb0ec1b6">threadpool</a>-&gt;GetRequest();
<a name="l00146"></a>00146 
<a name="l00147"></a>00147                         <span class="keywordflow">if</span>(temp!=NULL)
<a name="l00148"></a>00148                         {
<a name="l00149"></a>00149                                 printf(<span class="stringliteral">"Handling a request in thread=%d\n"</span>,<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#c70c7a3540e9cdad3e7eac570df96315">threadId</a>);
<a name="l00150"></a>00150                                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#ab45dae1f910885c22cebaa9f6e7feee">m_timeout</a> = temp-&gt;<a class="code" href="class_plugin_thread_pool_1_1_command.html#2830b94ad2a119732a997ee16caf71ac">GetTimeOut</a>()*1000; 
<a name="l00151"></a>00151                                 temp-&gt;<a class="code" href="class_plugin_thread_pool_1_1_command.html#bae83347a5d0fd5063355525f06a4ed0">execute</a>();
<a name="l00152"></a>00152                                 <span class="keyword">delete</span> temp;
<a name="l00153"></a>00153                                 
<a name="l00154"></a>00154                         }
<a name="l00157"></a>00157                 
<a name="l00159"></a>00159                         <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#7161bcf0e1166fbd59a86f303cb407a5">busy</a>=<span class="keyword">false</span>;
<a name="l00160"></a>00160                         <span class="comment">//printf("Thread %d is NOT busy\n",threadId);</span>
<a name="l00161"></a>00161 
<a name="l00162"></a>00162                 
<a name="l00164"></a>00164                         WaitForSingleObject(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#fe31064961fda989ca508ed4cd14294e">threadChkMutex</a>,INFINITE);
<a name="l00165"></a>00165                         {
<a name="l00166"></a>00166                                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#37253f8bdfe3899c4fe09602008b41fb">starttime</a>=0;
<a name="l00167"></a>00167                                 
<a name="l00168"></a>00168                                 <span class="comment">// Now check if the minimum thread count is exceeded; then delete this thread also</span>
<a name="l00169"></a>00169                                 <span class="comment">// so that there is no unnecessary max threads</span>
<a name="l00170"></a>00170                                 <span class="comment">//this has to be via last used time event</span>
<a name="l00171"></a>00171                                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#796e3dca1d2286547e1e75095272ef64">lastactivetime</a> = GetTickCount();
<a name="l00172"></a>00172                                 ReleaseMutex(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#fe31064961fda989ca508ed4cd14294e">threadChkMutex</a>);
<a name="l00173"></a>00173                         }
<a name="l00174"></a>00174                         
<a name="l00175"></a>00175                         
<a name="l00177"></a>00177                         ResetEvent(g_Event);
<a name="l00178"></a>00178 
<a name="l00179"></a>00179                 }
<a name="l00180"></a>00180 
<a name="l00183"></a>00183 
<a name="l00184"></a>00184                 printf(<span class="stringliteral">"Out of HandleRequest\n"</span>);
<a name="l00185"></a>00185                 
<a name="l00189"></a>00189                 
<a name="l00190"></a>00190                 <span class="keyword">delete</span> <span class="keyword">this</span>; <span class="comment">//ACP check</span>
<a name="l00191"></a>00191 
<a name="l00192"></a>00192                 <span class="comment">//Note before deleting this make sure that it is removed from thread chain</span>
<a name="l00193"></a>00193         }
<a name="l00194"></a>00194 
<a name="l00196"></a><a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#7ae01cce8c7c6f9d63c124194bd9d883">00196</a>         <span class="keywordtype">void</span> <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#7ae01cce8c7c6f9d63c124194bd9d883">HandleHungThreads</a>(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html">ThreadChain&lt;T&gt;</a>* prev)
<a name="l00197"></a>00197         {
<a name="l00199"></a>00199 
<a name="l00200"></a>00200                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html">ThreadChain&lt;T&gt;</a>* next_p= <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#39ed823eaf29897d799d283daee04c63">GetNext</a>();
<a name="l00201"></a>00201                 <span class="keywordtype">bool</span> bIsHung =<span class="keyword">false</span>;
<a name="l00202"></a>00202 
<a name="l00203"></a>00203                 <span class="keywordflow">if</span>(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#103d28f4e5269ac50c48450e8b4ba02e">IsHung</a>() || <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#435db32c0943a54cfd703185fb62f759">ReleaseIdleThread</a>())
<a name="l00204"></a>00204                 {
<a name="l00205"></a>00205                         printf(<span class="stringliteral">"In HandleHungThreads Thread %d is hung/idle!!\n"</span>,<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#c70c7a3540e9cdad3e7eac570df96315">threadId</a>);
<a name="l00206"></a>00206                         bIsHung = <span class="keyword">true</span>;
<a name="l00207"></a>00207                         <span class="keywordflow">if</span>(<span class="keyword">this</span> == <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#3dfa3c57d56981eae59af9acbb0ec1b6">threadpool</a>-&gt;root) 
<a name="l00208"></a>00208                         {
<a name="l00209"></a>00209                                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#3dfa3c57d56981eae59af9acbb0ec1b6">threadpool</a>-&gt;root = next_p;
<a name="l00210"></a>00210                                 prev= next_p;
<a name="l00211"></a>00211                         }
<a name="l00212"></a>00212                         <span class="keywordflow">else</span>
<a name="l00213"></a>00213                                 prev-&gt;<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#afa36db14f458aee323676f500e11ec8">next</a> = <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#39ed823eaf29897d799d283daee04c63">GetNext</a>(); <span class="comment">// reomove this item from thread chain link</span>
<a name="l00214"></a>00214                         
<a name="l00215"></a>00215                 }
<a name="l00216"></a>00216                 
<a name="l00217"></a>00217                 <span class="keywordflow">if</span>(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#afa36db14f458aee323676f500e11ec8">next</a> == 0) 
<a name="l00218"></a>00218                 {
<a name="l00219"></a>00219                         <span class="keywordflow">return</span>;
<a name="l00220"></a>00220                 }
<a name="l00221"></a>00221                 
<a name="l00222"></a>00222                 <span class="keywordflow">if</span>(bIsHung)
<a name="l00223"></a>00223                 {
<a name="l00224"></a>00224                         <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#0247af1e66ef2aa1152f7b6a81f32753">Release</a>(); 
<a name="l00225"></a>00225                         next_p-&gt;<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#7ae01cce8c7c6f9d63c124194bd9d883">HandleHungThreads</a>(prev);
<a name="l00226"></a>00226                         <span class="comment">//Release(); //dont release here </span>
<a name="l00227"></a>00227                         
<a name="l00228"></a>00228                 }
<a name="l00229"></a>00229                 <span class="keywordflow">else</span>
<a name="l00230"></a>00230                         <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#afa36db14f458aee323676f500e11ec8">next</a>-&gt;<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#7ae01cce8c7c6f9d63c124194bd9d883">HandleHungThreads</a>(<span class="keyword">this</span>);
<a name="l00231"></a>00231 
<a name="l00233"></a>00233                 
<a name="l00234"></a>00234         }
<a name="l00235"></a>00235 
<a name="l00237"></a><a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#e28a326e5c8e7e631e2c02f17bc8d02c">00237</a>         <span class="keywordtype">void</span> <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#e28a326e5c8e7e631e2c02f17bc8d02c">printChain</a>()
<a name="l00238"></a>00238         {
<a name="l00239"></a>00239                 printf(<span class="stringliteral">"Thread ID=%d\n"</span>,<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#c70c7a3540e9cdad3e7eac570df96315">threadId</a>);
<a name="l00240"></a>00240                 
<a name="l00242"></a>00242                 <span class="keywordflow">if</span>(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#afa36db14f458aee323676f500e11ec8">next</a> == 0)
<a name="l00243"></a>00243                         <span class="keywordflow">return</span>;
<a name="l00244"></a>00244                 
<a name="l00245"></a>00245                 <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#afa36db14f458aee323676f500e11ec8">next</a>-&gt;<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#e28a326e5c8e7e631e2c02f17bc8d02c">printChain</a>();
<a name="l00246"></a>00246         }
<a name="l00247"></a>00247 
<a name="l00248"></a>00248 
<a name="l00249"></a>00249 
<a name="l00251"></a><a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#39ed823eaf29897d799d283daee04c63">00251</a>         <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html">ThreadChain</a> * <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#39ed823eaf29897d799d283daee04c63">GetNext</a>()
<a name="l00252"></a>00252         {
<a name="l00253"></a>00253                 <span class="keywordflow">return</span> <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#afa36db14f458aee323676f500e11ec8">next</a>;
<a name="l00254"></a>00254         }
<a name="l00255"></a>00255 
<a name="l00258"></a><a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#103d28f4e5269ac50c48450e8b4ba02e">00258</a>         <span class="keywordtype">bool</span> <a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#103d28f4e5269ac50c48450e8b4ba02e">IsHung</a>()
<a name="l00259"></a>00259         {
<a name="l00261"></a>00261                 WaitForSingleObject(<a class="code" href="class_plugin_thread_pool_1_1_thread_chain.html#fe31064961fda989ca508ed4cd14294e">threadChkMutex</a>,INFINITE);