久久无码人妻一区二区三区午夜,亚洲欧美一级久久精品,久久久精品午夜免费不卡

自己造的一個線程類

#ifndef THREAD_H

#define THREAD_H

#include <stdio.h>//printf

#ifdef WIN32

#define WIN32_LEAN_AND_MEAN

#include <Windows.h>

#define THREAD_API DWORD WINAPI

#else

#include <pthread.h>

#define THREAD_API void*

#endif

class CThread

{

private:

#ifdef WIN32

HANDLE m_hThreadHandle;

DWORD m_dwThreadId;

#else

pthread_t m_dwThreadId;

#endif

bool m_bStopFlag;//是否已經“取消”該線程

bool m_bStarted;//線程已經啟動

private:

struct CThreadArg

{

CThread* m_pThread;//保存this指針

void* m_pArg;//保存start成員函數(shù)里面的arg參數(shù)指針

};

CThreadArg* m_pThrArg;

public:

CThread();

~CThread();

int Start(void* arg = NULL);

int Wait();//成功返回0；失敗-1

void Terminate(void);//強制退出

void SetStopFlag(); //協(xié)作性退出

bool GetStopFlag();

unsigned int GetID(void);

protected:

void SetThreadArg(CThreadArg* pThrArg = NULL);

CThreadArg* GetThreadArg(void);

virtual void Run(void* arg) = 0;//1.子類重載此函數(shù)，在run里面完成所有功能.2.子類要檢查GetStopFlag()，以配合對該線程的“停止”;或者采用強制終止Terminate()

private:

static THREAD_API Routine(void* arg);

};

#endif

下面是Thread.cpp

#include "Thread.h"

CThread::CThread():m_dwThreadId(0),m_bStopFlag(false),m_bStarted(false)

{

#ifdef WIN32

m_hThreadHandle = NULL;

SetThreadArg(NULL);

#endif

}

CThread::~CThread()

{

#ifdef WIN32

if (m_hThreadHandle != NULL)

{

CloseHandle(m_hThreadHandle);

}

#endif

if (m_pThrArg != NULL)

{

delete m_pThrArg;

m_pThrArg = NULL;

}

int CThread::Start(void* arg /* = NULL */)

{

if (m_bStarted)

{

return 0;

}

else

{

m_bStarted = true;

}

CThreadArg *pThrArg = new CThreadArg();

pThrArg->m_pArg = arg;

pThrArg->m_pThread = this;

#ifdef WIN32

m_hThreadHandle = CreateThread(NULL,NULL,Routine,(void*)pThrArg,NULL,&m_dwThreadId);

if (m_hThreadHandle != NULL)

{

m_pThrArg = pThrArg;

return 0;

}

else

{

delete pThrArg;

return -1;

}

#else

int ret = pthread_create(&m_dwThreadId,NULL,Routine,(void*)pThrArg);

if (ret == 0)

{

m_pThrArg = pThrArg;

return 0;

}

else

{

delete pThrArg;

return -1;

}

#endif

}

int CThread::Wait()

{

#ifdef WIN32

::WaitForSingleObject(m_hThreadHandle,INFINITE);

BOOL bRet = CloseHandle(m_hThreadHandle);

if (bRet)

{

m_hThreadHandle = NULL;

return 0;

}

else

return -1;

#else

int nRet = pthread_join(m_dwThreadId,NULL);

if(nRet == 0)

return 0;

else

return -1;

#endif

}

void CThread::SetStopFlag()

{

m_bStopFlag = true;

return;

}

bool CThread::GetStopFlag()

{

return m_bStopFlag;

}

void CThread::Terminate()

{

#ifdef WIN32

if (GetCurrentThreadId() == m_dwThreadId)

{

ExitThread(0);

return;

}

else

{

TerminateThread(m_hThreadHandle,0);

DWORD dwRet = 0;

GetExitCodeThread(m_hThreadHandle,&dwRet);

while (dwRet == STILL_ACTIVE)

{

printf("still active \n");

Sleep(100);

TerminateThread(m_hThreadHandle,0);

GetExitCodeThread(m_hThreadHandle,&dwRet);

}

#else

if (pthread_self() == m_dwThreadId)

{

pthread_exit(NULL);

return;

}

else

{

pthread_cancel(m_dwThreadId);

}

#endif

SetStopFlag();

return;

}

unsigned int CThread::GetID(void)

{

return (unsigned int) m_dwThreadId;

}

void CThread::SetThreadArg(CThreadArg* pThrArg /* = NULL */)

{

m_pThrArg = pThrArg;

return;

}

CThread::CThreadArg* CThread::GetThreadArg()

{

return m_pThrArg;

}

THREAD_API CThread::Routine(void* arg)

{

CThreadArg* pThrArg = (CThreadArg*)arg;

#ifndef WIN32

pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,NULL);

pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS,NULL);

#endif

pThrArg->m_pThread->Run(pThrArg->m_pArg);

return NULL;

}

自己用的，如果你有好的想法，告訴我！

posted on 2009-01-19 12:54 true 閱讀(2784) 評論(12) 編輯收藏引用所屬分類: linux

Feedback

# re: 自己造的一個線程類 2009-01-19 14:13 eXile

Win32最好不要使用CreateThread, 使用 _beginthreadex 回復更多評論

# re: 自己造的一個線程類[未登錄] 2009-01-19 20:58 true

@eXile
嗯，這個網上有這種說法，不過我目前主要在linux，至于win下沒那么講究。回復更多評論

# re: 自己造的一個線程類 2009-01-21 12:38 星綻紫輝

具體可查看《Windows核心編程》,里面講到CreateThread可能不會釋放tid線程塊，而C運行庫的_beginthreadex在內部調用了CreateThread，很好地解決了釋放問題。回復更多評論

# re: 自己造的一個線程類 2009-02-18 18:15 陳頭

linux下使用，竟然不能使用工廠模式，
創(chuàng)建線程工廠有錯誤。原因是Run方法，郁悶回復更多評論

# re: 自己造的一個線程類 2009-02-18 18:22 true

陳：
Run是純虛函數(shù)，必須重載，然后才能實例化。回復更多評論

# re: 自己造的一個線程類 2009-03-10 15:13 陳頭

請問如何顯示的析構 new 出來的線程類呢?
回復更多評論

# re: 自己造的一個線程類 2009-03-10 15:28 true

舉個例子：
class CThreadTest : public CThread
{
protected:
void Run(void* arg)
{
printf("arg = %s\n",(char*)arg);
sleep(10);
printf("after sleep 10s");
}

};
步驟：
1.char* pArg = "hello";CThreadTest *pTest = new CThreadTest
2.pTest->Start(pArg);
3.pTest->Wait();
4.delete pTest;
你可以在CThreadTest 里面實現(xiàn)，delete的時候，自動終止線程回復更多評論

# re: 自己造的一個線程類 2009-03-14 23:21 zengfanmaio

pthread_create第二個參數(shù)是空，默認有PTHREAD_CREATE_JOINABLE屬性。因此，析構的時候，也要調用一下pthread_join（對應Win32的CloseHandle）。如果設置了PTHREAD_CREATE_DETACHED就不需要。：）回復更多評論

# re: 自己造的一個線程類 2009-03-16 08:34 true

@zengfanmaio
好久不見！！回復更多評論

# re: 自己造的一個線程類 2009-03-24 19:20 老陳頭

謝謝回復更多評論

# re: 自己造的一個線程類[未登錄] 2009-09-11 20:16 欲三更

謝謝分享，很通用的設計，VCL類庫里的TThread類基本就是這個樣子。

說一點個人的想法：我自己寫的類也差不多是這樣，不過有一點差別：我個人認為“線程”和“線程要跑的任務”是兩個東西，前者是內核對象（抱歉，我總是改不了用win32本位思考）的抽象，跟具體功能沒關系，后者是功能的抽象，跟具體程序有關系。

所以我傾向于把static THREAD_API Routine(void* arg)分離出來，成為一個ITask接口。

這樣做還有一個好處，當Thread跑完了Task的代碼后可以阻塞在那里等待跑別的Task。

另外我對protobuf也蠻感興趣的，但是我有點看不懂那個東西，功力太淺：）回復更多評論

# re: 自己造的一個線程類 2009-09-11 20:34 true

@ 欲三更
線程的抽象問題，也算是見仁見智，你描述的方式類似boost的實現(xiàn)(好像是)，而博文中的抽象是基于“主動對象”這個概念的，我個人覺得，“主動對象”更容易理解。
libprotobuf是個好東東，多看幾遍就好了：），有啥問題可以一起交流。關于數(shù)據(jù)格式，還可以看一下json，感覺不錯。
回復更多評論

刷新評論列表

只有注冊用戶登錄后才能發(fā)表評論。
【推薦】100%開源！大型工業(yè)跨平臺軟件C++源碼提供，建模，組態(tài)！

相關文章: linux常用命令搜集給ZThread提供一個patch tcpdump的常用方式 C++實現(xiàn)的MD5算法 OCCI在linux上的編譯警告修改內核的部分參數(shù) 基礎庫的錯誤信息應該如何處理對基本類型的再包裝，方便了移植自己造的一個線程類 linux下信號處理函數(shù)實現(xiàn)的一點理解

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

網絡服務器軟件開發(fā)/中間件開發(fā)，關注ACE/ICE/boost

常用鏈接

留言簿(18)

隨筆分類

隨筆檔案

文章分類

文章檔案

好友博客

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜

Feedback