12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667 |
- #ifndef __THREADCOMPAREITEMMANAGER_H__
- #define __THREADCOMPAREITEMMANAGER_H__
- #include "spdlog/spdlog.h"
- #include "FromWebAPI.h"
- #include "CompareItemThread.h"
- #define CompareItemManager ThreadCompareItemManager::instance()
- class ThreadCompareItemManager
- {
- ThreadCompareItemManager();
- ThreadCompareItemManager(const ThreadCompareItemManager&) = delete;
- ThreadCompareItemManager& operator=(const ThreadCompareItemManager&) = delete;
- public:
- ~ThreadCompareItemManager();
- static ThreadCompareItemManager& instance()
- {
- static ThreadCompareItemManager instance;
- return instance;
- }
- /* 线程函数 */
- void thread_CompareItemManager();
- /* 添加对比项实例 */
- void addCompareItemThread(CompareItemThread* pThread);
- /* 给对比项套一层壳,这个函数就是新的线程,在里面new出新的对比项实例,防止Qt报线程归属权错误
- 在函数中将对比项实例插入到线程管理器中 */
- static void thread_compareItem(CalculateThreadInfo_t threadInfo);
- /* 更新基础设置信息,如数据库设置,噪音参数等 */
- bool updateBaseSettings();
-
- private:
- /* 处理对比项信息,新获取的和已有的对比 */
- void processCompareItemInfo(QList<CompareItemInfo_t>& createList,
- QList<CompareItemInfo_t>& updateList,
- QList<int>& deleteList);
- /* 处理需要删除的对比项线程 */
- void processDeleteCompareItemThreads(const QList<int>& deleteList);
- /* 更新正在运行的线程信息 */
- void updateRunningThreads(const QList<CompareItemInfo_t>& updateList);
- /* 创建新的线程 */
- bool createNewCompareItemThreads(const QList<CompareItemInfo_t>& createList);
- private:
- std::shared_ptr<spdlog::logger> m_logger = nullptr;
- FromWebAPI m_fromWebAPI; /* WebAPI处理类 */
- QString m_webAPIUrl; /* WebAPI地址 */
- QString m_webAPIID; /* WebAPI ID */
- QString m_appType; /* 应用类型 */
- std::mutex m_mutexCompareItemThreads; /* 对比项线程的互斥锁 */
- QList<CompareItemInfo_t> m_listNewItems; /* 对比项列表 */
- QMap<int, CompareItemThread*> m_mapThreads; /* 对比项线程列表,key是对比项ID,value是对应的线程指针 */
- };
- #endif
|