源码网商城,靠谱的源码在线交易网站 我的订单 购物车 帮助

源码网商城

C++封装线程类的实现方法

  • 时间:2020-07-28 04:45 编辑: 来源: 阅读:
  • 扫一扫,手机访问
摘要:C++封装线程类的实现方法
本文实例讲述了C++封装线程类的实现方法。分享给大家供大家参考。具体方法如下:
[u]复制代码[/u] 代码如下:
// 给主窗口的通知消息  #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++程序设计有所帮助。
  • 全部评论(0)
联系客服
客服电话:
400-000-3129
微信版

扫一扫进微信版
返回顶部