52 lines
1.4 KiB
C
52 lines
1.4 KiB
C
|
#pragma once
|
|||
|
|
|
|||
|
|
#include "DataMonitor.h"
|
|||
|
|
|
|||
|
|
class DataCollect
|
|||
|
|
{
|
|||
|
|
public:
|
|||
|
|
DataCollect();
|
|||
|
|
~DataCollect();
|
|||
|
|
|
|||
|
|
public:
|
|||
|
|
bool Initialize(std::vector<MonitorDataInfo> collectDataInfos, std::string dcsFilePath);
|
|||
|
|
|
|||
|
|
void start();
|
|||
|
|
|
|||
|
|
void stop();
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* @brief 从CSV文件读取下一行数据并更新执行时间
|
|||
|
|
* 如果文件读取完毕，将停止线程
|
|||
|
|
*/
|
|||
|
|
void updateData();
|
|||
|
|
|
|||
|
|
bool isRunning() const;
|
|||
|
|
|
|||
|
|
private:
|
|||
|
|
/**
|
|||
|
|
* @brief 线程执行函数
|
|||
|
|
*/
|
|||
|
|
void threadFunc();
|
|||
|
|
|
|||
|
|
void parseHeaderField(const std::string &headerField);
|
|||
|
|
|
|||
|
|
private:
|
|||
|
|
std::string m_outputFileName;
|
|||
|
|
std::ofstream m_outputFile;
|
|||
|
|
std::vector<MonitorDataInfo> m_collectDataInfos;
|
|||
|
|
std::vector<CSVHeaderField> m_headerFields;
|
|||
|
|
std::thread m_thread; ///< 数据采集线程
|
|||
|
|
std::atomic<bool> m_running; ///< 线程运行标志
|
|||
|
|
std::mutex m_mutex; ///< 互斥锁
|
|||
|
|
std::condition_variable m_cv; ///< 条件变量
|
|||
|
|
std::unordered_map<std::string, DataMonitorBasePtr>
|
|||
|
|
m_alreadyStartedMonitors; ///< 已经启动的数据监控器
|
|||
|
|
std::unordered_map<std::string, DataMonitorBasePtr>
|
|||
|
|
m_notStartedMonitors; ///< 未启动的数据监控器
|
|||
|
|
std::unordered_map<std::string, std::unordered_map<std::string, std::string>>
|
|||
|
|
m_data; ///< 采集到的数据
|
|||
|
|
std::atomic<int64_t> m_nextExecuteTime; ///< 下一次执行的时间点
|
|||
|
|
int m_collectDuration; ///< 采集时长（秒）
|
|||
|
|
int m_collectFrequency; ///< 采集频率（Hz）
|
|||
|
|
};
|