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

網絡服務器軟件開發/中間件開發,關注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>
            亚洲男人第一av网站| 裸体女人亚洲精品一区| 午夜视频一区二区| 亚洲精品小视频| 麻豆久久婷婷| 另类天堂视频在线观看| 久久人人97超碰精品888| 亚洲在线日韩| 99视频超级精品| 欲色影视综合吧| 欧美激情第10页| 欧美专区在线| 伊人久久综合| 国产精品亚洲аv天堂网| 免费观看亚洲视频大全| 欧美影院久久久| 久久一区亚洲| 国产精品久久久久9999高清| 国产精品高清免费在线观看| 久久精品一区二区三区四区| 欧美成人在线网站| 久久精品日韩| 蜜臀a∨国产成人精品 | 欧美亚洲视频一区二区| 亚洲美女黄色片| 最新国产の精品合集bt伙计| 在线精品视频在线观看高清| 欧美无乱码久久久免费午夜一区| 欧美a级一区| 欧美美女bbbb| 国产一区二区三区免费在线观看 | 久久久久国产精品www | 国产精品日韩在线一区| 国产日韩欧美一区在线| 亚洲人成艺术| 久久理论片午夜琪琪电影网| 日韩视频精品在线| 久久三级视频| 亚洲一区二区视频| 另类激情亚洲| 欧美a级片网站| 中日韩视频在线观看| 亚洲靠逼com| 欧美国产精品v| 99精品久久免费看蜜臀剧情介绍| 久久不见久久见免费视频1| 99国产精品自拍| 欧美精品久久99久久在免费线| 亚洲肉体裸体xxxx137| 亚洲日韩中文字幕在线播放| 久久嫩草精品久久久久| 最新国产の精品合集bt伙计| 亚洲精品小视频在线观看| 免费观看日韩| 欧美亚洲午夜视频在线观看| 欧美一级久久久久久久大片| 在线观看欧美日韩国产| 91久久精品日日躁夜夜躁欧美| 欧美一区午夜精品| 亚洲狼人精品一区二区三区| 欧美啪啪成人vr| 午夜精品久久久久久久久| 一区二区三区四区五区精品视频| 亚洲少妇最新在线视频| 一区二区视频免费完整版观看| 美日韩精品视频| 女人香蕉久久**毛片精品| 午夜精品视频网站| 欧美激情偷拍| 久久天堂精品| 国产精品三级视频| 亚洲精品一区二区三区四区高清 | 伊人成人在线| 国产三级精品在线不卡| 亚洲日本va在线观看| 国内精品国产成人| 亚洲一区3d动漫同人无遮挡| 亚洲美女中文字幕| 久久中文欧美| 欧美国产一区二区在线观看| 久久综合精品一区| 欧美性事免费在线观看| 亚洲精品资源| 欧美一二区视频| 欧美成人免费视频| 亚洲精品激情| 欧美一级午夜免费电影| 欧美性猛片xxxx免费看久爱| 亚洲巨乳在线| 欧美一区2区视频在线观看| 国产伦精品一区二区| 欧美一级欧美一级在线播放| 久久久久久午夜| 亚洲日本久久| 国产精品久久久爽爽爽麻豆色哟哟| 在线中文字幕不卡| 久久精品二区| aa级大片欧美三级| 欧美一区深夜视频| 日韩亚洲在线观看| 国产美女搞久久| 久久免费视频一区| 99国产精品一区| 欧美激情精品久久久久久大尺度| 亚洲一区二区三区四区五区黄| 韩国一区电影| 欧美一级日韩一级| 亚洲一区三区在线观看| 亚洲一区综合| 亚洲精品久久7777| 日韩一级在线| 一区二区欧美亚洲| 欧美成人免费一级人片100| 日韩视频三区| 亚洲精品免费在线| 久久天堂av综合合色| 欧美在线网站| 亚洲无限av看| 国产精品视频yy9099| 欧美日韩一区精品| 欧美国产精品久久| 欧美丰满少妇xxxbbb| 欧美日韩ab| 国产精品久久综合| 久久婷婷影院| 久久免费黄色| 美女在线一区二区| 欧美日韩国产美| 欧美日韩国内| 国产精品一区二区三区久久| 欧美亚洲第一区| 国产精品日韩欧美一区二区三区 | 亚洲午夜高清视频| 亚洲欧美日韩一区二区三区在线观看| 午夜久久电影网| 老司机精品福利视频| 欧美激情在线播放| 国产一区二区0| 亚洲一二三区精品| 亚洲第一综合天堂另类专| 亚洲欧美日韩一区在线| 蜜臀a∨国产成人精品| 欧美大片免费久久精品三p| 老司机午夜精品视频在线观看| 欧美国产日韩在线观看| 国产精品欧美精品| 亚洲先锋成人| 亚洲精品之草原avav久久| 久久综合999| 亚洲激情国产| 欧美日韩国产成人在线| 亚洲精品综合精品自拍| 亚洲高清视频在线观看| 欧美韩国日本一区| 亚洲私拍自拍| 亚洲欧美国产日韩天堂区| 国产婷婷色一区二区三区四区| 欧美一区=区| 久久久激情视频| 一区二区三区免费网站| 亚洲欧美高清| 亚洲精品国产欧美| 亚洲一区在线免费| 韩国精品在线观看| 亚洲国产日韩一区| 国产午夜精品理论片a级大结局| 欧美18av| 国产日韩欧美三级| 99爱精品视频| 亚洲国产成人在线| 午夜视频久久久| 一本色道久久加勒比精品| 久久精品最新地址| aa日韩免费精品视频一| 久久久五月婷婷| 久久久蜜臀国产一区二区| 国产精品高精视频免费| 欧美激情在线观看| 国产一区二区主播在线| 一本不卡影院| 亚洲一区二区在| 欧美精品一区二区在线播放| 欧美aⅴ一区二区三区视频| 狠狠久久五月精品中文字幕| 亚洲欧美福利一区二区| 亚洲欧美日韩精品久久久| 欧美日韩精品免费看| 亚洲日本va午夜在线影院| 亚洲精选视频免费看| 欧美黄网免费在线观看| 亚洲欧洲三级电影| 亚洲夜间福利| 国内欧美视频一区二区| 玖玖视频精品| 洋洋av久久久久久久一区| 性色一区二区三区| 亚洲国产精品va在线看黑人动漫| 欧美国产高清| 一本大道久久a久久综合婷婷| 欧美日韩视频在线一区二区|