linux版本中间件

ExecTask.h 496B

12345678910111213141516171819202122232425262728293031
  1. #pragma once
  2. #include <thread>
  3. #include <memory>
  4. #include <atomic>
  5. class ExecTask
  6. {
  7. public:
  8. ExecTask();
  9. ~ExecTask();
  10. bool SetRunTime(const std::string&strStart, const std::string&strEnd);
  11. protected:
  12. virtual void onConsumChange(const bool&bConsum) = 0;
  13. void dealTask(const std::string&strMessage);
  14. private:
  15. void __run();
  16. private:
  17. std::unique_ptr<std::thread> pListenThread;
  18. bool m_bStopThread;
  19. std::atomic_bool m_bIsDeal;
  20. std::string m_startTime;
  21. std::string m_endTime;
  22. };