Posted on 2009-01-18 19:07
S.l.e!ep.¢% 閱讀(303)
評論(0) 編輯 收藏 引用 所屬分類:
C++
????周末,總是有點那么的無聊。閑來沒事,想想每次自己要進行多線程編程時的痛苦,也并借機考慮設計了一個簡單的線程管理方式。? ????沒什么好說的,首先想想線程的創建,每次都要CreateThread,傳遞一堆的參數,還得沒事查查MSDN,唉,效率低啊。反正,對于我來說,線程基本都是缺省優先級、缺省安全的。不如把這些一起封裝了。 ????不多說,C++不用對象機制用什么?順便借鑒一下java。來個實際線程就是run,啟動采用start。 class thread { public: ???? thread( void ); ???? virtual ~thread( void ); ? ???? virtual void run() = 0; ? ???? void start(); }; ???? 這個也就是最基本的,基于對象的線程基類了。子類只需要實現run作為線程,調用start,就可以啟動線程了。線程的所需參數,很簡單,基于對象,有需要的,做為擴展類的成員變量——成員資源來訪問。 ??? 就這么簡單?線程訪問最大的問題——資源共享。那好,很容易想到互斥量。還有java的關鍵字synchronized,我們也就加一個鎖的概念。 class thread { public: ???? thread( void ); ???? virtual ~thread( void ); ? ???? virtual void run() = 0; ? ???? void start(); ? ???? static void syncLock( void *res,bool lock ); }; ????這樣,在最基本的線程資源——HANDLE,就可以被管理了,資源的訪問也可以通過lock和unlock來保護了。 ????實際中,很多時候,我們希望能限制或知道有多少線程在運行,那么再加一個運行線程記數功能。大多時候,往往是采用線程池,而且會根據CPU數目,決定運行的線程數目。我們干脆,再提供一個功能,限制對象上可以允許同時運行的線程數目。那好,改為(同時加上一些保護和注解): typedef unsigned int U32; /** ?* 線程對象 ?* 提供基于對象的線程處理接口 ?*/ class thread { public: ???? /** ????? * 線程基于對象的構造 ????? * para max 允許最多同時運行線程數 ????? */ ???? explicit thread( U32 max = -1 ); ???? virtual ~thread( void ); ? ???? /** ????? * 啟動一個線程 ????? * @return 啟動成功否 ????? */ ???? bool start( void ); ? ???? /** ????? * 對象上啟動的線程數 ????? * @return 線程數 ????? */ ???? U32 count( void ); ???? ???? /** ????? * 線程執行函數 ????? * @return 無 ????? */ ???? virtual void run( void ) = 0; ? ???? /** ????? * 為對象加解鎖 ????? * @return 無 ????? * @para res 要加解鎖的資源對象 ????? * @para lock 加鎖還是解鎖 ????? */ ???? static void syncLock( void *res,bool lock ); ? private: ???? thread( const thread &t ); ???? thread &operator=( const thread &t ); ? ???? void *m_datas; }; ????至于實現,我想不難。別忘了,對象銷毀時要等待所有線程結束,并釋放HANDLE資源哦。否則,線程會訪問錯誤的內存,還有線程HANDLE被泄漏的。(千萬別死鎖了,自己實現時就因為資源鎖來鎖去,鎖死了。) ????哈哈,就這么簡單,一個簡單的線程創建、管理就實現了。至于void *,你可以根據自己的實現去定義數據結構。 東西簡單,也就不貼出cpp源碼了,關鍵是個想到、做到的問題。 ????頭文件和lib,放在rar包吧,給大家一個實現后的參考。如果,發現有什么問題,可以隨時和我聯系。或者,您有更好的想法,并且愿意和我分享,那真是舉目明月,盡展抒懷。假如,您對有些語法,比如explicit不明,那么,建議您先看看有關C++的語法或者找您周圍的高手,讓他們洗腦一番。:} 謝謝閱讀,好就此打住。
配套程序下載:http://dev.gameres.com/Program/Other/thread.rar
|