/* * Task_Base 是任务基类,用作不同的模块之间的通信载体。 * 每一个模块创建一个任务子类,从Task_Base继承。 * 然后任务子类自定义一些数据和读写数据的接口函数。 * 然后在任务接受方实现 execute_task(Task_Base* p_laser_task) * */ #ifndef TASK_BASE_H #define TASK_BASE_H #include #include "../error_code/error_code.h" #include #include //任务单基类 class Task_Base { public: //任务超时时间默认值10000ms,10秒 #define TASK_OVER_TIME_DEFAULT 10000 //任务类型 enum Task_type { UNKNOW_TASK =0, //未知任务单//初始化,默认值 LASER_MANGER_SCAN_TASK =1, //雷达管理模块的扫描任务, LASER_BASE_SCAN_TASK =2, //单个雷达的扫描任务, LOCATE_MANGER_TASK =3, //测量任务 PLC_TASK =4, //上传PLC任务 WANJI_MANAGER_TASK, //万集雷达管理任务 WANJI_LIDAR_SCAN, //万集雷达扫描任务 WANJI_LIDAR_DETECT, //万集雷达定位任务 VELODYNE_MANAGER_TASK, //velodyne雷达管理任务 VELODYNE_LIDAR_SCAN, //velodyne雷达扫描任务 VELODYNE_LIDAR_DETECT, //velodyne雷达定位任务 DISPATCH_MANAGER_TASK, //调度管理任务 CARRIER_TASK, //搬运器任务 CATCHER_TASK, //抓取器任务 PASSAGEWAY_TASK, //通道口任务 }; //任务状态,如果任务故障,任务状态改为TASK_OVER,然后在m_task_error_manager 补充错误码。 enum Task_statu { TASK_CREATED = 0, //任务创建, 发送方 TASK_ISSUE = 1, //任务下发, 发送方 TASK_SIGNED = 2, //已签收, 接收方 TASK_WORKING = 3, //处理中, 接收方 TASK_OVER = 4, //已结束, 接收方 TASK_STOP = 5, //任务暂停, 接收方 TASK_ERROR = 11, //任务错误, 接收方 TASK_CANCEL = 21, //任务取消, 发送方 TASK_DEAD = 22, //任务死亡, 接收方 TASK_WITHDRAW = 31, //任务收回, 发送方 TASK_FREE = 32, //任务释放, 接收方 }; protected: //不允许构造基类,只允许子类构造,(多态) Task_Base(); public: ~Task_Base(); //初始化任务单,必须初始化之后才可以使用, // input:tast_receiver 接受对象 // input:task_over_time 超时时间 Error_manager task_init(void* p_tast_receiver, std::chrono::milliseconds task_over_time); //初始化任务单,必须初始化之后才可以使用, // input:task_statu 任务状态 // input:task_statu_information 状态说明 // input:tast_receiver 接受对象 // input:task_over_time 超时时间 Error_manager task_init(Task_statu task_statu, std::string task_statu_information, void* p_tast_receiver, std::chrono::milliseconds task_over_time); //任务单重置, 相当于重新创建, 会重置时间和错误码. Error_manager task_reset(); //更新任务单 //task_statu: 任务状态 //statu_information:状态说明 Error_manager update_statu(Task_statu task_statu,std::string statu_information=""); //判断是否超时。返回true表示任务超时,返回false表示任务没有超时 bool is_over_time(); //判断是否结束, TASK_OVER TASK_ERROR TASK_DEAD 都算结束 bool is_task_end(); public: //获取 任务单id unsigned int get_task_id(); //设置 任务单id // void set_task_id(unsigned int task_id) = delete; //获取 任务类型 Task_type get_task_type(); //设置 任务类型 // void set_task_type(Task_type task_type) = delete; //获取 任务单状态 Task_statu get_task_statu(); //设置 任务单状态 void set_task_statu(Task_statu task_statu); //获取 状态说明 std::string get_task_statu_information(); //设置 状态说明 void set_task_statu_information(std::string task_statu_information); //获取 错误码,返回引用。 Error_manager& get_task_error_manager(); //设置 错误码 void set_task_error_manager(Error_manager & error_manager); //比较覆盖错误码 void compare_and_cover_task_error_manager(Error_manager & error_manager); //获取任务接收方 void * get_tast_receiver(); //设置任务接收方 void set_tast_receiver(void * p_tast_receiver); //获取 任务创建的时间点 std::chrono::system_clock::time_point get_task_start_time(); //设置 任务创建的时间点 void set_task_start_time(std::chrono::system_clock::time_point task_start_time); //获取 任务超时的时限 std::chrono::milliseconds get_task_over_time(); //设置 任务超时的时限 void set_task_over_time(std::chrono::milliseconds task_over_time); protected: unsigned int m_task_id; //任务id, 每次新建任务, 自动+1, 用于多任务的管理 Task_type m_task_type; //任务类型,不允许中途修改 std::atomic m_task_statu; //任务状态 std::string m_task_statu_information; //任务状态说明 void* mp_tast_receiver; //任务接收方,Task_Base并不分配和释放内存。 //注:mp_tast_receiver是可选的,可以为NULL。如果为NULL,则需要task_command_manager去找到接收对象。 std::chrono::system_clock::time_point m_task_start_time; //任务创建的时间点 std::chrono::milliseconds m_task_over_time; //任务超时的时限 //注:std::chrono::system_clock::now(); //获取当前时间 //错误码,任务故障信息,任务输出 Error_manager m_task_error_manager; }; #endif //TASK_BASE_H