亚洲国产成人精品久久久国产成人一区二区三区综 ,九九精品99久久久香蕉,久久99九九国产免费看小说

自己造的一個(gè)線(xiàn)程類(lèi)

#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;//是否已經(jīng)“取消”該線(xiàn)程

bool m_bStarted;//線(xiàn)程已經(jīng)啟動(dòng)

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);//強(qiáng)制退出

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.子類(lèi)重載此函數(shù)，在run里面完成所有功能.2.子類(lèi)要檢查GetStopFlag()，以配合對(duì)該線(xiàn)程的“停止”;或者采用強(qiáng)制終止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 閱讀(2787) 評(píng)論(12) 編輯收藏引用所屬分類(lèi): linux

Feedback

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-01-19 14:13 eXile

Win32最好不要使用CreateThread, 使用 _beginthreadex 回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi)[未登錄](méi) 2009-01-19 20:58 true

@eXile
嗯，這個(gè)網(wǎng)上有這種說(shuō)法，不過(guò)我目前主要在linux，至于win下沒(méi)那么講究。回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-01-21 12:38 星綻紫輝

具體可查看《Windows核心編程》,里面講到CreateThread可能不會(huì)釋放tid線(xiàn)程塊，而C運(yùn)行庫(kù)的_beginthreadex在內(nèi)部調(diào)用了CreateThread，很好地解決了釋放問(wèn)題。回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-02-18 18:15 陳頭

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

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-02-18 18:22 true

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

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-03-10 15:13 陳頭

請(qǐng)問(wèn)如何顯示的析構(gòu) new 出來(lái)的線(xiàn)程類(lèi)呢?
回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-03-10 15:28 true

舉個(gè)例子：
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 里面實(shí)現(xiàn)，delete的時(shí)候，自動(dòng)終止線(xiàn)程回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-03-14 23:21 zengfanmaio

pthread_create第二個(gè)參數(shù)是空，默認(rèn)有PTHREAD_CREATE_JOINABLE屬性。因此，析構(gòu)的時(shí)候，也要調(diào)用一下pthread_join（對(duì)應(yīng)Win32的CloseHandle）。如果設(shè)置了PTHREAD_CREATE_DETACHED就不需要。：）回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-03-16 08:34 true

@zengfanmaio
好久不見(jiàn)！！回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-03-24 19:20 老陳頭

謝謝回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi)[未登錄](méi) 2009-09-11 20:16 欲三更

謝謝分享，很通用的設(shè)計(jì)，VCL類(lèi)庫(kù)里的TThread類(lèi)基本就是這個(gè)樣子。

說(shuō)一點(diǎn)個(gè)人的想法：我自己寫(xiě)的類(lèi)也差不多是這樣，不過(guò)有一點(diǎn)差別：我個(gè)人認(rèn)為“線(xiàn)程”和“線(xiàn)程要跑的任務(wù)”是兩個(gè)東西，前者是內(nèi)核對(duì)象（抱歉，我總是改不了用win32本位思考）的抽象，跟具體功能沒(méi)關(guān)系，后者是功能的抽象，跟具體程序有關(guān)系。

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

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

另外我對(duì)protobuf也蠻感興趣的，但是我有點(diǎn)看不懂那個(gè)東西，功力太淺：）回復(fù) 更多評(píng)論

# re: 自己造的一個(gè)線(xiàn)程類(lèi) 2009-09-11 20:34 true

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

刷新評(píng)論列表

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

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

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問(wèn) Chat2DB 管理

網(wǎng)絡(luò)服務(wù)器軟件開(kāi)發(fā)/中間件開(kāi)發(fā)，關(guān)注ACE/ICE/boost

常用鏈接

留言簿(18)

隨筆分類(lèi)

隨筆檔案

文章分類(lèi)

文章檔案

好友博客

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

Feedback