青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

網絡服務器軟件開發/中間件開發,關注ACE/ICE/boost

C++博客 首頁 新隨筆 聯系 聚合 管理
  152 Posts :: 3 Stories :: 172 Comments :: 0 Trackbacks
#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成員函數里面的arg參數指針
    }
;

    CThreadArg
* m_pThrArg;
public:
    CThread();    
    
~CThread();
    
int Start(void* arg = NULL);
    
int  Wait();//成功返回0;失敗-1

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

    
void  SetStopFlag();    //協作性退出
    bool  GetStopFlag();    


    unsigned 
int GetID(void);
    
    
protected:    
    
void SetThreadArg(CThreadArg* pThrArg = NULL);
    CThreadArg
* GetThreadArg(void);

    
virtual void Run(void* arg) = 0;//1.子類重載此函數,在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 閱讀(2799) 評論(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下使用,竟然不能使用工廠模式,
創建線程工廠有錯誤。原因是Run方法,郁悶  回復  更多評論
  

# re: 自己造的一個線程類 2009-02-18 18:22 true
陳:
Run是純虛函數,必須重載,然后才能實例化。  回復  更多評論
  

# 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 里面實現,delete的時候,自動終止線程  回復  更多評論
  

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

pthread_create第二個參數是空,默認有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的實現(好像是),而博文中的抽象是基于“主動對象”這個概念的,我個人覺得,“主動對象”更容易理解。
libprotobuf是個好東東,多看幾遍就好了:),有啥問題可以一起交流。關于數據格式,還可以看一下json,感覺不錯。
  回復  更多評論
  

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            欧美aⅴ一区二区三区视频| 噜噜噜噜噜久久久久久91| 午夜一区二区三视频在线观看 | 欧美成人乱码一区二区三区| 激情欧美一区| 免费亚洲电影在线| 欧美成人精品不卡视频在线观看 | 最新日韩中文字幕| 日韩视频不卡中文| 国产欧美短视频| 蜜桃av一区二区三区| 免费在线亚洲欧美| 一区二区三区免费看| 亚洲欧美日韩综合国产aⅴ| 国产欧美日本一区二区三区| 久久久久久久尹人综合网亚洲 | 一区二区三区国产在线| 99精品视频免费| 欧美一区二区视频在线观看2020| 国产欧美精品一区aⅴ影院| 亚洲欧洲日本国产| 欧美喷潮久久久xxxxx| 欧美日韩国产区一| 欧美精品一二三| 亚洲砖区区免费| 亚洲人体一区| 国产精品久久久久久一区二区三区| 久久国产日本精品| 亚洲一区二区三区免费视频| 午夜精品视频一区| 久久成人精品无人区| 久久久精品日韩| 午夜精品免费在线| 欧美国产日韩亚洲一区| 久久夜色精品亚洲噜噜国产mv | 亚洲精品护士| 这里只有精品视频在线| 亚洲作爱视频| 欧美人与性动交cc0o| 午夜精品视频在线观看一区二区| 亚洲天堂激情| 欧美一区二区三区成人| 国产精品久久久久国产精品日日| 欧美电影专区| 99国产精品久久| 精品999在线播放| 一区二区三区久久精品| av成人免费| 欧美高清成人| 亚洲丰满在线| 亚洲电影免费| 欧美大片在线观看| 久久精品视频在线观看| 亚洲网友自拍| 亚洲午夜日本在线观看| 亚洲美女视频在线观看| 国产日韩av高清| 欧美色图天堂网| 国产在线播放一区二区三区| 欧美91福利在线观看| 韩国自拍一区| 欧美大尺度在线| 久久国产精品久久w女人spa| 欧美一级欧美一级在线播放| 欧美日韩高清免费| 日韩视频中文字幕| 亚洲久久在线| 国产精品美女久久久久久免费| 亚洲免费黄色| 亚洲视频www| 国精品一区二区| 欧美韩日一区二区三区| 亚洲缚视频在线观看| 国语自产精品视频在线看| 亚洲一区高清| 欧美在线免费| 欧美中文字幕第一页| 欧美一级片在线播放| 亚洲日本免费| 欧美日韩精品久久| 亚洲一区视频在线| 国产精品视频区| 亚洲精品在线电影| 一本一本久久a久久精品综合妖精 一本一本久久a久久精品综合麻豆 | 久久成人免费电影| 在线日韩视频| 欧美色图天堂网| 久久精品日韩一区二区三区| 亚洲大胆美女视频| 亚洲欧美国产日韩中文字幕| 国自产拍偷拍福利精品免费一| 你懂的亚洲视频| 亚洲综合成人在线| 亚洲电影免费在线观看| 欧美一级在线播放| 亚洲精品一区二区在线观看| 国产女主播一区| 欧美精品一区二区三区很污很色的 | 欧美日韩国产免费| 久久国产夜色精品鲁鲁99| 亚洲欧洲偷拍精品| 久久视频精品在线| 亚洲一区二区三区久久| 亚洲国产91| 国产欧美亚洲视频| 欧美三区美女| 欧美va亚洲va香蕉在线| 亚洲欧美国产制服动漫| 亚洲大胆在线| 久久久久久电影| 午夜精品短视频| 日韩午夜在线| 亚洲国产精品久久久久婷婷884 | 亚洲精品韩国| 欧美www视频在线观看| 久久er精品视频| 亚洲一区二区精品| 亚洲卡通欧美制服中文| 一区二区三区在线免费观看 | 中文久久精品| 亚洲精品久久久久久久久久久久| 久久人人爽爽爽人久久久| 亚洲免费视频成人| 一二三四社区欧美黄| 最近中文字幕日韩精品| 伊大人香蕉综合8在线视| 国产欧美三级| 国产精品永久免费视频| 国产精品久久久久久久久久尿| 夜夜嗨一区二区| 一区二区三区在线免费播放| 欧美性天天影院| 久久免费一区| 欧美va亚洲va国产综合| 亚洲一级一区| 免费观看在线综合| 亚洲淫性视频| 久久久久99| 亚洲小视频在线观看| 麻豆精品国产91久久久久久| 亚洲视频免费在线| 在线一区二区三区四区| 亚洲一区视频在线| 国产精品夜夜夜| 国产精品不卡在线| 欧美午夜宅男影院在线观看| 欧美精品九九| 欧美日韩国产在线| 欧美日韩三级| 国产精品国产三级国产普通话蜜臀| 欧美日韩国产不卡在线看| 欧美日韩美女一区二区| 欧美日韩国产成人精品| 欧美日韩精品一区视频| 国产精品成人观看视频国产奇米| 国产精品第一页第二页第三页| 国产精品免费福利| 国产一区二区在线观看免费| 国内精品久久久久影院色| 在线看片一区| 99国产精品国产精品久久| 亚洲视频综合| 久久国产加勒比精品无码| 久久综合狠狠综合久久综合88| 牛牛国产精品| 日韩视频在线你懂得| 亚洲尤物在线| 久久久久久9| 欧美国产一区二区| 国产精品久久影院| 精品成人国产在线观看男人呻吟| 亚洲国产99精品国自产| 这里只有精品丝袜| 久久久久久黄| 亚洲人成在线影院| 亚洲欧美在线网| 免费成人性网站| 欧美日韩在线观看一区二区| 国产精品一区二区三区四区五区| 一区免费在线| 亚洲免费在线视频一区 二区| 久久亚洲欧美| 一本色道久久88亚洲综合88| 久久精品99| 国产精品igao视频网网址不卡日韩 | 99re6这里只有精品| 欧美一区中文字幕| 亚洲激情自拍| 欧美资源在线观看| 欧美日韩一级片在线观看| 黄色成人av网站| 亚洲欧美视频在线观看视频| 亚洲二区视频| 欧美一区网站| 国产精品高潮呻吟视频| 亚洲精品国产精品国产自| 久久久久国产精品麻豆ai换脸| 日韩亚洲欧美一区| 你懂的视频一区二区| 国产一区二区三区高清播放|