本文实例讲述了C++封装线程类的实现方法。分享给大家供大家参考。具体方法如下：
#define WM_CUTTERSTART WM_USER + 100 // wParam == xxx lParam==xxxx
/*
外面调用这个类时，只需要IsRunning() Startxxx(xxx) Suspendxxx() Resumexxx() Stopxxx()
*/
/*
m_bContinue在真正的工作代码DoSomething中检测，在退出和类析构时设为FALSE,在Reset时和构造时设为TRUE 标志内部是否继续工作
m_bRunning 在Startxxx Suspendxxx Resumexxx 中检测，在构造时和Reset时设为FALSE,在_ThreadEntry得到WaitForSingleObject时设为TRUE
外部通过IsRunning得到是否正在运行
*/
class CMyClass
{
public:
// 工作退出代码
enum ExitCode{
exitSuccess, // 成功完成任务
exitUserForce, // 用户终止
exitError, // 源文件出错
};
// 构造函数
CMyClass(HWND hWndNotify); //接收窗口句柄
// 属性 对外开放
BOOL IsRunning() const { return m_bRunning; } //对外
// 操作 对外开放
BOOL Startxxx(xxx);
BOOL Suspendxxx();
BOOL Resumexxx();
void Stopxxx();
// 具体实现
public:
~CFileCutter(); //析构
protected:
// 重置参数信息和状态标志
void Reset();
// 真正的工作核心代码
void DoSomething();
// 工作线程
UINT friend _ThreadEntry(LPVOID lpParam);
// 状态标志
BOOL m_bContinue; // 是否继续工作 DoSomething中检测，如果在DoSomething中不m_bContinue，就中止工作
BOOL m_bRunning; // 是否处于工作状态
// 同步以上两组数据
CRITICAL_SECTION m_cs; // Data gard
private:
// 对象的生命周期全局有效的数据
HWND m_hWndNotify; // 接受消息通知事件的窗口句柄
HANDLE m_hWorkEvent; // 通知开始工作的事件对象句柄
CWinThread* m_pThread; // 工作线程
BOOL m_bSuspend; // 暂停标志
BOOL m_bExitThread; // 退出标志
};
//构造
CMyClass::CMyClass()
{
// 初始化全局有效变量
m_hWndNotify = hWndNotify;
m_bExitThread = FALSE;
m_bSuspend = FALSE;
// 创建等待事件对象
m_hWorkEvent = ::CreateEvent(NULL, FALSE, FALSE, NULL);
// 创建工作线程
m_pThread = AfxBeginThread(_CutterEntry, this, THREAD_PRIORITY_NORMAL, 0, CREATE_SUSPENDED, NULL);
m_pThread->m_bAutoDelete = FALSE;
m_pThread->ResumeThread();
// 初始化工作期间有效变量
m_bContinue = TRUE; //工作函数不被打断，这个标志就为TRUE,在工作函数中检测这个值
m_bRunning = FALSE; //线程函数在WaitForSingleObject，所以还是FALSE
// 创建关键代码段
::InitializeCriticalSection(&m_cs);
}
// 内部工作线程
UINT _ThreadEntry(LPVOID lpParam)
{
// 得到CMyClass对象的指针
CMyClass* pMyClass = (CMyClass*)lpParam;
// 循环处理用户的工作请求
while(::WaitForSingleObject(pMyClass->m_hWorkEvent, INFINITE) == WAIT_OBJECT_0 &&
!pMyClass->m_bExitThread)
{
// 设置状态标志，说明正在工作
::EnterCriticalSection(&pCutter->m_cs);
pMyClass->m_bRunning = TRUE;
::LeaveCriticalSection(&pCutter->m_cs);
// 开始真正的工作
pMyClass->DoSomething()
// 准备接受新的工作任务
pMyClass->Reset(); //这个函数中设置一下各标志的值
}
return 0;
}
void CMyClass::Reset()
{
::EnterCriticalSection(&m_cs);
// 重置状态标志
m_bContinue = TRUE;
m_bRunning = FALSE;
::LeaveCriticalSection(&m_cs);
}
CMyClass::~CMyClass()
{
// 设置结束标志
m_bExitThread = TRUE;
// 设置强制退出标志
::EnterCriticalSection(&m_cs);
m_bContinue = FALSE;
::LeaveCriticalSection(&m_cs);
//**********很重要******************************************
// 防止线程在m_hWorkEvent事件上等待
::SetEvent(m_hWorkEvent);
// 确保工作线程结束
::WaitForSingleObject(m_pThread->m_hThread, INFINITE);
// 释放所有资源
::CloseHandle(m_hWorkEvent);
::DeleteCriticalSection(&m_cs);
delete m_pThread;
}
BOOL CMyClass::Startxxx(xxx)
{
if(m_bRunning)
return FALSE;
// 通知线程