task_base.h 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136
  1. /*
  2. * Task_Base 是任务基类,用作不同的模块之间的通信载体。
  3. * 每一个模块创建一个任务子类,从Task_Base继承。
  4. * 然后任务子类自定义一些数据和读写数据的接口函数。
  5. * 然后在任务接受方实现 execute_task(Task_Base* p_laser_task)
  6. * */
  7. #ifndef TASK_BASE_H
  8. #define TASK_BASE_H
  9. #include <string>
  10. #include "../error_code/error_code.h"
  11. #include <chrono>
  12. //任务超时时间默认值10000ms,10秒
  13. #define TASK_OVER_TIME_DEFAULT 10000
  14. //任务类型
  15. enum Task_type
  16. {
  17. UNKNOW_TASK =0, //未知任务单//初始化,默认值
  18. LASER_MANGER_SCAN_TASK =1, //雷达管理模块的扫描任务,
  19. LASER_BASE_SCAN_TASK =2, //单个雷达的扫描任务,
  20. LOCATE_MANGER_TASK =3, //测量任务
  21. PLC_TASK =4, //上传PLC任务
  22. WANJI_MANAGER_TASK, //万集雷达管理任务
  23. WANJI_LIDAR_SCAN, //万集雷达扫描任务
  24. WANJI_LIDAR_DETECT, //万集雷达定位任务
  25. VELODYNE_MANAGER_TASK, //velodyne雷达管理任务
  26. VELODYNE_LIDAR_SCAN, //velodyne雷达扫描任务
  27. VELODYNE_LIDAR_DETECT, //velodyne雷达定位任务
  28. };
  29. //任务状态,如果任务故障,任务状态改为TASK_OVER,然后在m_task_error_manager 补充错误码。
  30. enum Task_statu
  31. {
  32. TASK_CREATED =0, //创建状态,默认值
  33. TASK_SIGNED =1, //已签收
  34. TASK_WORKING =2, //处理中
  35. TASK_OVER =3, //已结束
  36. TASK_ERROR =11, //任务错误
  37. //前面的状态由接收方选择, TASK_DEAD 则是发送方选择.
  38. TASK_DEAD =12, //当任务超时,发送方让任务死亡,
  39. };
  40. //任务单基类
  41. class Task_Base
  42. {
  43. protected:
  44. //不允许构造基类,只允许子类构造,(多态)
  45. Task_Base();
  46. public:
  47. ~Task_Base();
  48. //初始化任务单,必须初始化之后才可以使用,
  49. // input:task_statu 任务状态
  50. // input:task_statu_information 状态说明
  51. // input:tast_receiver 接受对象
  52. // input:task_over_time 超时时间
  53. Error_manager task_init(Task_statu task_statu,
  54. std::string task_statu_information,
  55. void* p_tast_receiver,
  56. std::chrono::milliseconds task_over_time);
  57. //更新任务单
  58. //task_statu: 任务状态
  59. //statu_information:状态说明
  60. Error_manager update_statu(Task_statu task_statu,std::string statu_information="");
  61. //判断是否超时。返回true表示任务超时,返回false表示任务没有超时
  62. bool is_over_time();
  63. //判断是否结束, TASK_OVER TASK_ERROR TASK_DEAD 都算结束
  64. bool is_task_end();
  65. public:
  66. //获取 任务单id
  67. unsigned int get_task_id();
  68. //设置 任务单id
  69. // void set_task_id(unsigned int task_id) = delete;
  70. //获取 任务类型
  71. Task_type get_task_type();
  72. //设置 任务类型
  73. // void set_task_type(Task_type task_type) = delete;
  74. //获取 任务单状态
  75. Task_statu get_task_statu();
  76. //设置 任务单状态
  77. void set_task_statu(Task_statu task_statu);
  78. //获取 状态说明
  79. std::string get_task_statu_information();
  80. //设置 状态说明
  81. void set_task_statu_information(std::string task_statu_information);
  82. //获取 错误码,返回引用。
  83. Error_manager& get_task_error_manager();
  84. //设置 错误码
  85. void set_task_error_manager(Error_manager & error_manager);
  86. //比较覆盖错误码
  87. void compare_and_cover_task_error_manager(Error_manager & error_manager);
  88. //获取任务接收方
  89. void * get_tast_receiver();
  90. //设置任务接收方
  91. void set_tast_receiver(void * p_tast_receiver);
  92. //获取 任务创建的时间点
  93. std::chrono::system_clock::time_point get_task_start_time();
  94. //设置 任务创建的时间点
  95. void set_task_start_time(std::chrono::system_clock::time_point task_start_time);
  96. //获取 任务超时的时限
  97. std::chrono::milliseconds get_task_over_time();
  98. //设置 任务超时的时限
  99. void set_task_over_time(std::chrono::milliseconds task_over_time);
  100. protected:
  101. unsigned int m_task_id; //任务id, 每次新建任务, 自动+1, 用于多任务的管理
  102. Task_type m_task_type; //任务类型,不允许中途修改
  103. Task_statu m_task_statu; //任务状态
  104. std::string m_task_statu_information; //任务状态说明
  105. void* mp_tast_receiver; //任务接收方,Task_Base并不分配和释放内存。
  106. //注:mp_tast_receiver是可选的,可以为NULL。如果为NULL,则需要task_command_manager去找到接收对象。
  107. std::chrono::system_clock::time_point m_task_start_time; //任务创建的时间点
  108. std::chrono::milliseconds m_task_over_time; //任务超时的时限
  109. //注:std::chrono::system_clock::now(); //获取当前时间
  110. //错误码,任务故障信息,任务输出
  111. Error_manager m_task_error_manager;
  112. };
  113. #endif //TASK_BASE_H