C++封装线程类的实现方法
更新时间:2020年4月25日 17:40 点击:2063
本文实例讲述了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;
// 通知线程开始工作
::SetEvent(m_hWorkEvent);
return TRUE;
}
BOOL CMyClass::Suspendxxx()
{
if(!m_bRunning)
return FALSE;
// 暂停工作线程
if(!m_bSuspend)
{
m_pThread->SuspendThread();
m_bSuspend = TRUE;
}
return TRUE;
}
BOOL CMyClass::Resumexxx()
{
if(!m_bRunning)
return FALSE;
// 唤醒工作线程
if(m_bSuspend)
{
m_pThread->ResumeThread();
m_bSuspend = FALSE;
}
return TRUE;
}
void CMyClass::Stopxxx()
{
// 设置强制退出标志
::EnterCriticalSection(&m_cs);
m_bContinue = FALSE;
::LeaveCriticalSection(&m_cs);
// 防止线程处于暂停状态
ResumeCutter();
}
//-------------------------实现代码-------------------------//
//真正的工作代码
void CMyClass::DoSomething()
{
// 通知用户,出错
::PostMessage(m_hWndNotify, wm_xxx, exitError, 0);
// 通知用户,开始工作
::PostMessage(m_hWndNotify, WM_XXXSTART, 0, XX);
// 首先判断是否要求终止执行
if(!m_bContinue)
{
//释放资源
xxxx;
if(!m_bExitThread)
::PostMessage(m_hWndNotify, WM_XXXXSTOP, XX, XX);
return;
}
// 通知用户,工作完成
::PostMessage(m_hWndNotify, WM_CUTTERSTOP, exitSuccess, nCompleted);
}
#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;
// 通知线程开始工作
::SetEvent(m_hWorkEvent);
return TRUE;
}
BOOL CMyClass::Suspendxxx()
{
if(!m_bRunning)
return FALSE;
// 暂停工作线程
if(!m_bSuspend)
{
m_pThread->SuspendThread();
m_bSuspend = TRUE;
}
return TRUE;
}
BOOL CMyClass::Resumexxx()
{
if(!m_bRunning)
return FALSE;
// 唤醒工作线程
if(m_bSuspend)
{
m_pThread->ResumeThread();
m_bSuspend = FALSE;
}
return TRUE;
}
void CMyClass::Stopxxx()
{
// 设置强制退出标志
::EnterCriticalSection(&m_cs);
m_bContinue = FALSE;
::LeaveCriticalSection(&m_cs);
// 防止线程处于暂停状态
ResumeCutter();
}
//-------------------------实现代码-------------------------//
//真正的工作代码
void CMyClass::DoSomething()
{
// 通知用户,出错
::PostMessage(m_hWndNotify, wm_xxx, exitError, 0);
// 通知用户,开始工作
::PostMessage(m_hWndNotify, WM_XXXSTART, 0, XX);
// 首先判断是否要求终止执行
if(!m_bContinue)
{
//释放资源
xxxx;
if(!m_bExitThread)
::PostMessage(m_hWndNotify, WM_XXXXSTOP, XX, XX);
return;
}
// 通知用户,工作完成
::PostMessage(m_hWndNotify, WM_CUTTERSTOP, exitSuccess, nCompleted);
}
希望本文所述对大家的C++程序设计有所帮助。
相关文章
C# WinForm多线程解决界面卡死问题的完美解决方案,使用BeginInvoke
问题描述:当我们的界面需要在程序运行中不断更新数据时,当一个textbox的数据需要变化时,为了让程序执行中不出现界面卡死的现像,最好的方法就是多线程来解决一个主线程来创建界...2020-06-24- vector是表示可以改变大小的数组的序列容器,本文主要介绍了C++STL标准库std::vector的使用详解,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2022-03-06
- 这篇文章主要介绍了C++中取余运算的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-23
- 这篇文章主要介绍了C++ string常用截取字符串方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-04-25
- 本文通过例子,讲述了C++调用C#的DLL程序的方法,作出了以下总结,下面就让我们一起来学习吧。...2020-06-25
基于vue-simple-uploader封装文件分片上传、秒传及断点续传的全局上传插件功能
这篇文章主要介绍了基于vue-simple-uploader封装文件分片上传、秒传及断点续传的全局上传插件,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-02-23- 本篇文章主要介绍了C++中四种加密算法之AES源代码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。...2020-04-25
- 今天小编就为大家分享一篇关于C#开启线程的四种方式示例详解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧...2020-06-25
- 这篇文章主要介绍了C#停止线程的方法,实例分析了C#正确停止线程的实现技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 整数拆分,指把一个整数分解成若干个整数的和。本文重点给大家介绍C++ 整数拆分方法详解,非常不错,感兴趣的朋友一起学习吧...2020-04-25
- 这篇文章主要介绍了C++中Sort函数详细解析,sort函数是algorithm库下的一个函数,sort函数是不稳定的,即大小相同的元素在排序后相对顺序可能发生改变...2022-08-18
- 这篇文章主要介绍了C# 线程相关知识,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下...2020-11-03
- 这篇文章主要介绍了c# 多线程处理多个数据的方法,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下...2021-03-31
- 这篇文章主要介绍了C++万能库头文件在vs中的安装步骤(图文),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-23
- 这篇文章主要介绍了C#实现跨线程操作控件方法,主要采用异步访问方式实现,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了C#基于委托实现多线程之间操作的方法,实例分析了C#的委托机制与多线程交互操作的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了C++ bitset用法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-04-25
- 本篇文章小编并不是为大家讲解string类型的用法,而是讲解我个人比较好奇的问题,就是string 类型占几个字节...2020-04-25
- 这篇文章主要介绍了C#多线程中的异常处理操作,涉及C#多线程及异常的捕获、处理等相关操作技巧,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了c# 线程同步的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2020-08-29