1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 |
- #ifndef _DATAMANAGER_H_
- #define _DATAMANAGER_H_
- #include "Global.h"
- class CDataManager
- {
- public:
- CDataManager();
- ~CDataManager();
- static CDataManager *GetInstance()
- {
- static CDataManager Instance;
- return &Instance;
- }
- //实时提交
- int StartRealTimeSubmitThread();
- int EndofRealTimeSubmitThread();
- int RealTimeSubmitWork();
- static DWORD WINAPI RealTimeSubmitThread(LPVOID lpParam);
- DWORD ReadOldLog(std::vector<STAllLog> &vtAllLog); // 配置文件中设置要读取的txt;
- //全部提交
- int StartSubmitAllThread();
- int EndofSubmitAllThread();
- int SubmitAllWork();
- static DWORD WINAPI SubmitAllDataThread(LPVOID lpParam);
-
- ThreadSection* ReturnSection(){return &s_critSection;}
- //写数据
- DWORD WriteIntoDatabase(std::vector<STGeneralLogData>* pVData);
-
- BOOL IsThreadRuning(){return m_bThreadRuning;}
- BOOL IsSubmitAllThreadRuning();
- private:
- ThreadSection s_critSection;
- //实时提交
- HANDLE _hThread; // 线程句柄;
- BOOL m_bThreadRuning;
-
- // 全部提交;
- HANDLE _hThread1; // 线程句柄1;
- HANDLE _hCtrl1; // 线程事件1;
- BOOL m_bThreadRuning1;
-
-
- };
- #endif
|