Posted on 2009-01-18 19:07
S.l.e!ep.￠% 閱讀(312)
評論(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
|