_beginThreadex建立多線程解讀

 

_beginThreadex建立多線程解讀


_beginThreadex建立多線程解讀
html

1、須要的頭文件支持

 #include <process.h>         // for _beginthread() 編程

須要的設置:ProjectàSetting-->C/C++-->User run-time library 選擇Debug Multithreaded 或者Multithreaded。即便用: MT或MTD。 windows

源碼以下: 安全

[cpp]  view plain copy
  1. #include <stdio.h>  
  2. #include <string>             // for STL string class  
  3. #include <windows.h>          // for HANDLE  
  4. #include <process.h>          // for _beginthread()  
  5. using namespace std;  
  6.   
  7. class ThreadX  
  8. {  
  9. private:  
  10.   int loopStart;  
  11.   int loopEnd;  
  12.   int dispFrequency;  
  13. public:  
  14.   string threadName;  
  15.   
  16.   ThreadX( int startValue, int endValue, int frequency )  
  17.   {  
  18.     loopStart = startValue;  
  19.     loopEnd = endValue;  
  20.     dispFrequency = frequency;  
  21.   }  
  22.   
  23.   static unsigned __stdcall ThreadStaticEntryPoint(void * pThis)  
  24.   {  
  25.       ThreadX * pthX = (ThreadX*)pThis;   // the tricky cast  
  26.       pthX->ThreadEntryPoint();           // now call the true entry-point-function  
  27.       return 1;                           // the thread exit code  
  28.   }  
  29.   
  30.   void ThreadEntryPoint()  
  31.   {  
  32.     for (int i = loopStart; i <= loopEnd; ++i)  
  33.     {  
  34.       if (i % dispFrequency == 0)  
  35.       {  
  36.           printf( "%s: i = %d\n", threadName.c_str(), i );  
  37.       }  
  38.     }  
  39.     printf( "%s thread terminating\n", threadName.c_str() );  
  40.   }  
  41. };  
  42.   
  43.   
  44. int main()  
  45. {  
  46.     ThreadX * o1 = new ThreadX( 0, 1, 2000 );  
  47.   
  48.     HANDLE   hth1;  
  49.     unsigned  uiThread1ID;  
  50.   
  51.     hth1 = (HANDLE)_beginthreadex( NULL,         // security  
  52.                                    0,            // stack size  
  53.                                    ThreadX::ThreadStaticEntryPoint,  
  54.                                    o1,           // arg list  
  55.                                    CREATE_SUSPENDED,  // so we can later call ResumeThread()  
  56.                                    &uiThread1ID );  
  57.   
  58.     if ( hth1 == 0 )  
  59.         printf("Failed to create thread 1\n");  
  60.   
  61.     DWORD   dwExitCode;  
  62.     GetExitCodeThread( hth1, &dwExitCode );  // should be STILL_ACTIVE = 0x00000103 = 259  
  63.     printf( "initial thread 1 exit code = %u\n", dwExitCode );  
  64.   
  65.     o1->threadName = "t1";  
  66.   
  67.     ThreadX * o2 = new ThreadX( -100000, 0, 2000 );  
  68.   
  69.     HANDLE   hth2;  
  70.     unsigned  uiThread2ID;  
  71.   
  72.     hth2 = (HANDLE)_beginthreadex( NULL,         // security  
  73.                                    0,            // stack size  
  74.                                    ThreadX::ThreadStaticEntryPoint,  
  75.                                    o2,           // arg list  
  76.                                    CREATE_SUSPENDED,  // so we can later call ResumeThread()  
  77.                                    &uiThread2ID );  
  78.   
  79.     if ( hth2 == 0 )  
  80.         printf("Failed to create thread 2\n");  
  81.   
  82.     GetExitCodeThread( hth2, &dwExitCode );  // should be STILL_ACTIVE = 0x00000103 = 259  
  83.     printf( "initial thread 2 exit code = %u\n", dwExitCode );  
  84.   
  85.     o2->threadName = "t2";  
  86.   
  87.     ResumeThread( hth1 );   // serves the purpose of Jaeschke's t1->Start()  
  88.     ResumeThread( hth2 );     
  89.   
  90.     WaitForSingleObject( hth1, INFINITE );  
  91.     WaitForSingleObject( hth2, INFINITE );  
  92.   
  93.     GetExitCodeThread( hth1, &dwExitCode );  
  94.     printf( "thread 1 exited with code %u\n", dwExitCode );  
  95.   
  96.     GetExitCodeThread( hth2, &dwExitCode );  
  97.     printf( "thread 2 exited with code %u\n", dwExitCode );  
  98.   
  99.     CloseHandle( hth1 );  
  100.     CloseHandle( hth2 );  
  101.   
  102.     delete o1;  
  103.     o1 = NULL;  
  104.   
  105.     delete o2;  
  106.     o2 = NULL;  
  107.   
  108.     printf("Primary thread terminating.\n");  
  109.     return 0;  
  110. }  

2、解釋

(1)若是你正在編寫C/C++代碼,決不該該調用CreateThread。相反,應該使用VisualC++運行期庫函數_beginthreadex,退出也應該使用_endthreadex。若是不使用Microsoft的VisualC++編譯器,你的編譯器供應商有它本身的CreateThread替代函數。無論這個替代函數是什麼,你都必須使用。 多線程

(2)由於_beginthreadex和_endthreadex是CRT線程函數,因此必須注意編譯選項runtimelibaray的選擇,使用MTMTD。[MultiThreaded , Debug MultiThreaded]。 app

(3)_beginthreadex函數的參數列表與CreateThread函數的參數列表是相同的,可是參數名和類型並不徹底相同。這是由於Microsoft的C/C++運行期庫的開發小組認爲,C/C++運行期函數不該該對Windows數據類型有任何依賴。_beginthreadex函數也像CreateThread那樣,返回新建立的線程的句柄。 函數

下面是關於_beginthreadex的一些要點: oop

1)每一個線程均得到由C/C++運行期庫的堆棧分配的本身的tiddata內存結構。(tiddata結構位於Mtdll.h文件中的VisualC++源代碼中)。 ui

2)傳遞給_beginthreadex的線程函數的地址保存在tiddata內存塊中。傳遞給該函數的參數也保存在該數據塊中。 spa

3)_beginthreadex確實從內部調用CreateThread,由於這是操做系統瞭解如何建立新線程的惟一方法。

4)當調用CreatetThread時,它被告知經過調用_threadstartex而不是pfnStartAddr來啓動執行新線程。還有,傳遞給線程函數的參數是tiddata結構而不是pvParam的地址。

5)若是一切順利,就會像CreateThread那樣返回線程句柄。若是任何操做失敗了,便返回NULL。

(4)_endthreadex的一些要點:

C運行期庫的_getptd函數內部調用操做系統的TlsGetValue函數,該函數負責檢索調用線程的tiddata內存塊的地址。

而後該數據塊被釋放,而操做系統的ExitThread函數被調用,以便真正撤消該線程。固然,退出代碼要正確地設置和傳遞。

(5)雖然也提供了簡化版的的_beginthread和_endthread,可是可控制性太差,因此通常不使用。

(6)線程handle由於是內核對象,因此須要在最後closehandle。

(7)更多的API:

HANDLE GetCurrentProcess();

HANDLE GetCurrentThread();

DWORD GetCurrentProcessId();

DWORD GetCurrentThreadId()。

DWORD SetThreadIdealProcessor(HANDLE hThread,DWORDdwIdealProcessor);

BOOL SetThreadPriority(HANDLE hThread,int nPriority);

BOOL SetPriorityClass(GetCurrentProcess(),  IDLE_PRIORITY_CLASS);

BOOL GetThreadContext(HANDLE hThread,PCONTEXTpContext);

BOOL SwitchToThread();

3、注意

(1)C++主線程的終止,同時也會終止全部主線程建立的子線程,無論子線程有沒有執行完畢。因此上面的代碼中若是不調用WaitForSingleObject,則2個子線程t1和t2可能並無執行完畢或根本沒有執行。

(2)若是某線程掛起,而後有調用WaitForSingleObject等待該線程,就會致使死鎖。因此上面的代碼若是不調用resumethread,則會死鎖。

 

4、爲何用_beginthreadex而不是CreateThread?

爲何要用C運行時庫的_beginthreadex代替操做系統的CreateThread來建立線程?

來源自自19997MSJ雜誌的《Win32 Q&A》欄目

你也許會說我一直用CreateThread來建立線程,一直都工做得好好的,爲何要用_beginthreadex來代替CreateThread,下面讓我來告訴你爲何。

回答一個問題能夠有兩種方式,一種是簡單的,一種是複雜的。

若是你不肯意看下面的長篇大論,那我能夠告訴你簡單的答案:_beginthreadex在內部調用了CreateThread,在調用以前_beginthreadex作了不少的工做,從而使得它比CreateThread更安全

 轉載一部分,本身總結了一部分。

_beginthreadex 必定要本身寫 CloseHandle 能夠不用 _endthreadex

2012-2-17 11:01| 發佈者: benben| 查看: 1092| 評論: 0

摘要: _beginthreadex 必定要本身寫 CloseHandle 能夠不用 _endthreadex天哪,很久不 寫忘記了.一直記得線程的句柄只是 createthread 才須要關閉,多是我用 AfxBeginThread 太多了.之後直接這樣好了 ::CloseHandle((HANDLE ...

_beginthreadex 必定要本身寫 CloseHandle 能夠不用 _endthreadex

 

天哪,很久不 寫忘記了.一直記得線程的句柄只是 createthread 才須要關閉,多是我用 AfxBeginThread 太多了.

之後直接這樣好了 ::CloseHandle((HANDLE)_beginthreadex(NULL, 0,threadRun_client,(void *)tp, 0, &runThreadID ));

--------------------------------------------------

http://wellwy.blog.51cto.com/blog/1609602/492009

 

_beginthreadex相關的東東 2011-02-12 16:57:52

標籤:_beginthreadex

談到Handle的問題,_beginthread的對應函數_endthread自動的調用了CloseHandle,而_beginthreadex的對應函數_endthreadex則沒有,因此CloseHandle不管如何都是要調用的不過_endthread能夠幫你執行本身沒必要寫,其餘兩種就須要本身寫!(Jeffrey   Richter強烈推薦儘可能不用顯式的終止函數,用天然退出的方式,天然退出固然就必定要本身寫CloseHandle) 


 

 
//////////////////////////////

在Windows下面,比較常見的多線程建立函數是CreateThread(Windows自帶的)和_beginthread、_beginthreadex(C運行庫的)。

強烈推薦只用_beginthreadex,參數上面與CreateThread基本同樣,比CreateThread好的就是,它給每一個線程維護一個tiddata數據塊,這對於多線程環境很是重要。《Windows核心編程》裏也是這麼說的。

用_beginthreadex還有個好處是,線程結束後,不會本身執行CloseHandle函數,這樣的話,對於WaitFor系列函數的調用就比較方便了。_beginthread在線程結束的時候是會本身CloseHandle。


 

//////////////////////////

_beginthread()存在幾個缺陷以下: 

1     建立時不能將線程掛起。 
2     _beginthread產生出來的線程會首先關閉本身的handle,這樣作是爲了隱藏win32的實現細節,所以_beginthread()傳回的參數可能在當時是不可用的。所以,沒有這個handle,你就沒法等待他結束,沒法改變其參數,沒法得到結束代碼。 



///////////////////////////////////

You can call _endthread or _endthreadex explicitly to terminate a thread; however, _endthread or _endthreadex is called automatically when the thread returns from the routine passed as a parameter. Terminating a thread with a call to endthread or _endthreadex helps to ensure proper recovery of resources allocated for the thread.

相關文章
相關標籤/搜索